diff --git a/src/AasxServerStandardBib/EventService.cs b/src/AasxServerStandardBib/EventService.cs index 03d8d295..7d7b7847 100644 --- a/src/AasxServerStandardBib/EventService.cs +++ b/src/AasxServerStandardBib/EventService.cs @@ -923,55 +923,57 @@ private List CollectPayloadForRestApi(SqlConditions? securitySqlCo foreach (var sm in smSearchList) { - var entryType = EventPayloadType.Updated; - if (sm.TimeStampCreate > diffTime) + if (sm.SemanticId != null) { - entryType = EventPayloadType.Created; - } + var entryType = EventPayloadType.Updated; + if (sm.TimeStampCreate > diffTime) + { + entryType = EventPayloadType.Created; + } - if (sm.TimeStampTree > timeStampMax) - { - timeStampMax = sm.TimeStampTree; - } + if (sm.TimeStampTree > timeStampMax) + { + timeStampMax = sm.TimeStampTree; + } - var sourceString = Program.externalBlazor + "/submodels/" + Base64UrlEncoder.Encode(sm.Identifier); + var sourceString = Program.externalBlazor + "/submodels/" + Base64UrlEncoder.Encode(sm.Identifier); - var entry = new EventPayload(isREST); + var entry = new EventPayload(isREST); - entry.source = sourceString; - entry.SetSubmodelType(entryType); - entry.SetTime(sm.TimeStampTree); + entry.source = sourceString; + entry.SetSubmodelType(entryType); + entry.SetTime(sm.TimeStampTree); - //entry.time = TimeStamp.TimeStamp.DateTimeToString(sm.TimeStampTree); + //entry.time = TimeStamp.TimeStamp.DateTimeToString(sm.TimeStampTree); - entry.SetDataschema(EventPayload.REST_API_SM_SCHEMA_URL); + entry.SetDataschema(EventPayload.REST_API_SM_SCHEMA_URL); - if (sm.SemanticId != null && !isREST) - { - entry.semanticid = sm.SemanticId; - } - if (isREST && sm.Identifier != null) - { - entry.subject = sm.Identifier; - } + if (sm.Identifier != null) + { + entry.subject = sm.Identifier; + } - if (withPayload) - { - var s = CrudOperator.ReadSubmodel(db, sm, loadIntoMemoryWithoutElements: true, - securitySqlConditions: securitySqlConditions, - skipAllowCheck: true); - if (s != null) + if (withPayload) { - var j = Jsonization.Serialize.ToJsonObject(s); - if (j != null) + var s = CrudOperator.ReadSubmodel(db, sm, loadIntoMemoryWithoutElements: true, + securitySqlConditions: securitySqlConditions, + skipAllowCheck: true); + if (s != null) { - entry.data = ConvertSmJsonToRestApiSpecSmJson(j); + var j = Jsonization.Serialize.ToJsonObject(s); + if (j != null) + { + entry.data = ConvertSmJsonToRestApiSpecSmJson(j); + } } } + + entry.semanticid = sm.SemanticId; + + _logger.LogDebug($"Event id: {entry.id}, Type: {entry.type}"); + eventPayloadList.Add(entry); } - _logger.LogDebug($"Event id: {entry.id}, Type: {entry.type}"); - eventPayloadList.Add(entry); } }