Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 1 | /******************************************************************************* |
| 2 | * Copyright (c) 2020 Robert Bosch GmbH |
| 3 | * Author: Constantin Ziesche (constantin.ziesche@bosch.com) |
| 4 | * |
| 5 | * This program and the accompanying materials are made available under the |
| 6 | * terms of the Eclipse Public License 2.0 which is available at |
| 7 | * http://www.eclipse.org/legal/epl-2.0 |
| 8 | * |
| 9 | * SPDX-License-Identifier: EPL-2.0 |
| 10 | *******************************************************************************/ |
| 11 | using BaSyx.API.AssetAdministrationShell.Extensions; |
| 12 | using BaSyx.Models.Connectivity.Descriptors; |
| 13 | using BaSyx.Models.Core.AssetAdministrationShell.Generics; |
| 14 | using BaSyx.Models.Core.Common; |
| 15 | using BaSyx.Utils.ResultHandling; |
| 16 | using System; |
| 17 | using System.Collections.Generic; |
| 18 | using System.Linq; |
| 19 | |
| 20 | namespace BaSyx.API.Components |
| 21 | { |
| 22 | public class SubmodelRepositoryServiceProvider : ISubmodelRepositoryServiceProvider |
| 23 | { |
| 24 | public IEnumerable<ISubmodel> Submodels => GetBinding(); |
| 25 | |
| 26 | private Dictionary<string, ISubmodelServiceProvider> SubmodelServiceProviders { get; } |
| 27 | |
| 28 | private ISubmodelRepositoryDescriptor _serviceDescriptor; |
| 29 | public ISubmodelRepositoryDescriptor ServiceDescriptor |
| 30 | { |
| 31 | get |
| 32 | { |
| 33 | if (_serviceDescriptor == null) |
| 34 | _serviceDescriptor = new SubmodelRepositoryDescriptor(Submodels, null); |
| 35 | |
| 36 | return _serviceDescriptor; |
| 37 | } |
| 38 | private set |
| 39 | { |
| 40 | _serviceDescriptor = value; |
| 41 | } |
| 42 | } |
| 43 | public SubmodelRepositoryServiceProvider(ISubmodelRepositoryDescriptor descriptor) : this() |
| 44 | { |
| 45 | ServiceDescriptor = descriptor; |
| 46 | } |
| 47 | |
| 48 | public SubmodelRepositoryServiceProvider() |
| 49 | { |
| 50 | SubmodelServiceProviders = new Dictionary<string, ISubmodelServiceProvider>(); |
| 51 | } |
| 52 | |
| 53 | public void BindTo(IEnumerable<ISubmodel> submodels) |
| 54 | { |
| 55 | foreach (var submodel in submodels) |
| 56 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 57 | RegisterSubmodelServiceProvider(submodel.Identification.Id, submodel.CreateServiceProvider()); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 58 | } |
| 59 | ServiceDescriptor = ServiceDescriptor ?? new SubmodelRepositoryDescriptor(submodels, null); |
| 60 | } |
| 61 | public IEnumerable<ISubmodel> GetBinding() |
| 62 | { |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 63 | List<ISubmodel> submodels = new List<ISubmodel>(); |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 64 | var retrievedSubmodelServiceProviders = GetSubmodelServiceProviders(); |
| 65 | if (retrievedSubmodelServiceProviders.TryGetEntity(out IEnumerable<ISubmodelServiceProvider> serviceProviders)) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 66 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 67 | foreach (var serviceProvider in serviceProviders) |
| 68 | { |
| 69 | ISubmodel binding = serviceProvider.GetBinding(); |
| 70 | submodels.Add(binding); |
| 71 | } |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 72 | } |
| 73 | return submodels; |
| 74 | } |
| 75 | |
| 76 | public IResult<ISubmodel> CreateSubmodel(ISubmodel submodel) |
| 77 | { |
| 78 | if (submodel == null) |
| 79 | return new Result<ISubmodel>(new ArgumentNullException(nameof(submodel))); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 80 | |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 81 | var registered = RegisterSubmodelServiceProvider(submodel.Identification.Id, submodel.CreateServiceProvider()); |
| 82 | if (!registered.Success) |
| 83 | return new Result<ISubmodel>(registered); |
| 84 | |
| 85 | var retrievedSubmodelServiceProvider = GetSubmodelServiceProvider(submodel.Identification.Id); |
| 86 | if (retrievedSubmodelServiceProvider.TryGetEntity(out ISubmodelServiceProvider serviceProvider)) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 87 | return new Result<ISubmodel>(true, serviceProvider.GetBinding()); |
| 88 | else |
| 89 | return new Result<ISubmodel>(false, new Message(MessageType.Error, "Could not retrieve Submodel Service Provider")); |
| 90 | } |
| 91 | |
| 92 | public IResult DeleteSubmodel(string submodelId) |
| 93 | { |
| 94 | if (string.IsNullOrEmpty(submodelId)) |
| 95 | return new Result<ISubmodel>(new ArgumentNullException(nameof(submodelId))); |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 96 | return UnregisterSubmodelServiceProvider(submodelId); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 97 | } |
| 98 | |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 99 | public IResult<ISubmodelServiceProvider> GetSubmodelServiceProvider(string id) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 100 | { |
| 101 | if (SubmodelServiceProviders.TryGetValue(id, out ISubmodelServiceProvider submodelServiceProvider)) |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 102 | return new Result<ISubmodelServiceProvider>(true, submodelServiceProvider); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 103 | else |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 104 | return new Result<ISubmodelServiceProvider>(false, new NotFoundMessage(id)); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 105 | } |
| 106 | |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 107 | public IResult<IEnumerable<ISubmodelServiceProvider>> GetSubmodelServiceProviders() |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 108 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 109 | if (SubmodelServiceProviders.Values == null) |
| 110 | return new Result<IEnumerable<ISubmodelServiceProvider>>(false, new NotFoundMessage("Submodel Service Providers")); |
| 111 | |
| 112 | return new Result<IEnumerable<ISubmodelServiceProvider>>(true, SubmodelServiceProviders.Values?.ToList()); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 113 | } |
| 114 | |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 115 | public IResult<ISubmodelDescriptor> RegisterSubmodelServiceProvider(string id, ISubmodelServiceProvider submodelServiceProvider) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 116 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 117 | if (SubmodelServiceProviders.ContainsKey(id)) |
| 118 | SubmodelServiceProviders[id] = submodelServiceProvider; |
| 119 | else |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 120 | SubmodelServiceProviders.Add(id, submodelServiceProvider); |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 121 | |
| 122 | return new Result<ISubmodelDescriptor>(true, submodelServiceProvider.ServiceDescriptor); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 123 | } |
| 124 | |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 125 | public IResult UnregisterSubmodelServiceProvider(string id) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 126 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 127 | if (SubmodelServiceProviders.ContainsKey(id)) |
| 128 | { |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 129 | SubmodelServiceProviders.Remove(id); |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 130 | return new Result(true); |
| 131 | } |
| 132 | else |
| 133 | return new Result(false, new NotFoundMessage(id)); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 134 | } |
| 135 | |
| 136 | public IResult<ISubmodel> RetrieveSubmodel(string submodelId) |
| 137 | { |
Constantin Ziesche | eb74d64 | 2020-11-04 17:57:12 +0100 | [diff] [blame^] | 138 | var retrievedSubmodelServiceProvider = GetSubmodelServiceProvider(submodelId); |
| 139 | if(retrievedSubmodelServiceProvider.TryGetEntity(out ISubmodelServiceProvider serviceProvider)) |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 140 | { |
| 141 | ISubmodel binding = serviceProvider.GetBinding(); |
| 142 | return new Result<ISubmodel>(true, binding); |
| 143 | } |
| 144 | return new Result<ISubmodel>(false, new NotFoundMessage("Submodel Service Provider")); |
| 145 | } |
| 146 | |
| 147 | public IResult<IElementContainer<ISubmodel>> RetrieveSubmodels() |
| 148 | { |
Constantin Ziesche | 0821550 | 2020-09-21 19:08:32 +0200 | [diff] [blame] | 149 | return new Result<IElementContainer<ISubmodel>>(true, new ElementContainer<ISubmodel>(null, Submodels)); |
Constantin Ziesche | 8b4a64d | 2020-06-25 11:52:09 +0200 | [diff] [blame] | 150 | } |
| 151 | |
| 152 | public IResult UpdateSubmodel(string submodelId, ISubmodel submodel) |
| 153 | { |
| 154 | if (string.IsNullOrEmpty(submodelId)) |
| 155 | return new Result<ISubmodel>(new ArgumentNullException(nameof(submodelId))); |
| 156 | if (submodel == null) |
| 157 | return new Result<ISubmodel>(new ArgumentNullException(nameof(submodel))); |
| 158 | return CreateSubmodel(submodel); |
| 159 | } |
| 160 | } |
| 161 | } |