View Javadoc
1   /*
2    * Licensed to The Apereo Foundation under one or more contributor license
3    * agreements. See the NOTICE file distributed with this work for additional
4    * information regarding copyright ownership.
5    *
6    *
7    * The Apereo Foundation licenses this file to you under the Educational
8    * Community License, Version 2.0 (the "License"); you may not use this file
9    * except in compliance with the License. You may obtain a copy of the License
10   * at:
11   *
12   *   http://opensource.org/licenses/ecl2.txt
13   *
14   * Unless required by applicable law or agreed to in writing, software
15   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
16   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
17   * License for the specific language governing permissions and limitations under
18   * the License.
19   *
20   */
21  package org.opencastproject.assetmanager.api.fn;
22  
23  import org.opencastproject.assetmanager.api.Property;
24  import org.opencastproject.assetmanager.api.Snapshot;
25  import org.opencastproject.assetmanager.api.query.ARecord;
26  
27  import java.util.LinkedHashSet;
28  import java.util.List;
29  import java.util.stream.Collectors;
30  
31  /**
32   * Functions to deal with {@link ARecord}s.
33   */
34  public final class ARecords {
35    public static String getMediaPackageId(LinkedHashSet<ARecord> records) {
36      return records.stream()
37          .map(r -> r.getMediaPackageId())
38          .findFirst()
39          .get();
40  
41    }
42  
43    public static List<Property> getProperties(LinkedHashSet<ARecord> records) {
44      return records.stream()
45          .map(r -> r.getProperties())
46          .flatMap(List::stream)
47          .collect(Collectors.toList());
48    };
49  
50    public static boolean hasProperties(ARecord record) {
51      return record.getProperties().isEmpty();
52    }
53  
54    /**
55     * Get the snapshot from a record.
56     *
57     * @see ARecord#getSnapshot()
58     */
59    public static List<Snapshot> getSnapshot(LinkedHashSet<ARecord> records) {
60      return records.stream()
61          .map(r -> r.getSnapshot())
62          .filter(s -> s.isPresent())
63          .map(s -> s.get())
64          .collect(Collectors.toList());
65  
66    }
67  
68    private ARecords() {
69    }
70  }