corDB/corDbEntityAttrsSet.c at main · SEAMWARE/corDB · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
//
// FILE            corDbEntityAttrsSet.c
//
// AUTHOR          Ken Zangelin
//
// Copyright 2026 Seamware
// SPDX-License-Identifier: Apache-2.0
//

#include <stdbool.h>                                 // bool
#include <string.h>                                   // strcmp

#include "corTree/corTreeFree.h"                      // corTreeFree
#include "corTree/corTreeChildReplace.h"              // corTreeChildReplace
#include "corTree/CorNode.h"                          // CorNode
#include "corTree/corTreeLookup.h"                    // corTreeLookup

#include "corNgsild/ldEntityAttrsSet.h"                // ldEntityAttrsSet
#include "corNgsild/LdVocab.h"                         // LD_VOCAB_MODIFIED_AT, LD_VOCAB_SCOPE

#include "db/DbDriver.h"                              // DB_OK, DB_NOT_FOUND
#include "corDB/corDbSysTimes.h"                      // corDbTreeIn, corDbTreeOut, corDbFullView, corDbAttrFold
#include "corDB/corDbIndex.h"        // corDbIndexLookup, corDbIndexChanged
#include "corDB/corDbPersist.h"                      // corDbPersistAppend
#include "corDB/corDbHistoryWrite.h"                 // corDbHistoryCreated, ...Replaced, ...Merged, ...Deleted
#include "corRest/CorRestState.h"                    // corRest (kallocP - the history's scratch)
#include "corDB/corDbStore.h"          // corDbEntities
#include "corDB/corDbEntityAttrsSet.h" // Own interface


// -----------------------------------------------------------------------------
//
// corDbEntityAttrsSet -
//
int corDbEntityAttrsSet(Tenant* tenantP, const char* entityId,
                        CorNode* fragmentDb, bool overwriteScope,
                        uint64_t ts, LdMergeReport* reportP)
{
  COR_DB_WRITE(tenantP);

  CorNode* entities = corDbEntities(tenantP);
  if (entities == NULL)
    return DB_NOT_FOUND;

  //
  // One hop via the id index instead of a walk of the whole store with a
  // corTreeLookup per entity. The loop shape is kept so the body below is unchanged:
  // indexed, it runs exactly once for the hit and not at all for a miss;
  // unindexed - a store that predates the index - it walks as it always did.
  //
  CorDbStore* idxStoreP = corDbStoreOf(tenantP);
  CorNode*    idxHitP   = corDbIndexLookup(idxStoreP, entityId);
  bool        indexed   = (idxStoreP != NULL) && (idxStoreP->idToPrevEntity != NULL);

  for (CorNode* eP = indexed ? idxHitP : entities->value.head;
       eP != NULL;
       eP = indexed ? NULL : eP->next)
  {
    CorNode* idP = corTreeLookup(eP, "id");
    if (idP != NULL && idP->type == CorString && strcmp(idP->value.s, entityId) == 0)
    {
      // NULL allocator → malloc heap (tenant store lifetime)
      ldEntityAttrsSet(eP, fragmentDb, overwriteScope, ts, reportP, NULL);   // keeps an inherited createdAt inherited (0x04)

      // The attributes it wrote: their types kept in the nodes, as corDbTreeIn keeps them
      for (CorNode* mP = (fragmentDb != NULL) ? fragmentDb->value.head : NULL; mP != NULL; mP = mP->next)
      {
        if ((mP->type == CorObject) && (mP->name != NULL))
          corDbAttrFold(corTreeLookup(eP, mP->name));
      }

      //
      // The log record: the members the fragment names, as the entity has them now, and what the
      // write refreshes beside them - not the entity (corDbPersistAppendAttrs)
      //
      const char* names[64];
      int         n    = 0;
      bool        many = false;

      for (CorNode* mP = (fragmentDb != NULL) ? fragmentDb->value.head : NULL; mP != NULL; mP = mP->next)
      {
        if (n == 61)
        {
          many = true;
          break;
        }
        names[n++] = mP->name;
      }

      if (many)                                      // that many attributes: the entity
        corDbPersistAppend(corDbLockedStore->persistP, CorDbLogEntityPut, eP);
      else
      {
        names[n++] = LD_VOCAB_MODIFIED_AT;
        names[n++] = "type";
        names[n++] = LD_VOCAB_SCOPE;
        corDbPersistAppendAttrs(corDbLockedStore->persistP, eP, names, n);
      }
      corDbIndexChanged(corDbLockedStore, eP, names, many ? -1 : n);   // what the type and value indexes hold of it
      corDbHistoryMerged(corDbLockedStore, eP, reportP, corRest.kallocP);
      return DB_OK;
    }
  }

  return DB_NOT_FOUND;
}