[Do not merge] Auth server

.eslintrc.json

@@ -0,0 +1,37 @@
+{
+  "extends": "@dcl/eslint-config/sdk",
+  "parserOptions": {
+    "project": [
+      "packages/@dcl/sdk/types/tsconfig.ecs7.json",
+      "packages/@dcl/ecs/tsconfig.json",
+      "packages/@dcl/sdk-commands/tsconfig.json",
+      "packages/@dcl/sdk/tsconfig.json",
+      "packages/@dcl/playground-assets/tsconfig.json",
+      "packages/@dcl/react-ecs/tsconfig.json",
+      "scripts/tsconfig.json",
+      "test/tsconfig.json",
+      "test/ecs/snippets/tsconfig.json"
+    ]
+  },
+  "rules": {
+    "no-param-reassign": "warn",
+    "no-console": "error",
+    "@typescript-eslint/no-unused-vars": [
+      "warn",
+      {
+        "ignoreRestSiblings": true,
+        "argsIgnorePattern": "^_",
+        "varsIgnorePattern": "^_|ReactEcs",
+        "caughtErrorsIgnorePattern": "^_"
+      }
+    ]
+  },
+  "overrides": [
+    {
+      "files": ["packages/@dcl/ecs/**/*.ts", "packages/@dcl/sdk/**/*.ts", "scripts/**/*.ts", "test/**/*.ts"],
+      "rules": {
+        "no-console": "off"
+      }
+    }
+  ]
+}

.github/workflows/ci.yml

@@ -3,13 +3,14 @@ on:
     branches:
       - main
       - experimental
+      - auth-server
   pull_request:
   release:
     types:
       - created
 
 env:
-  BRANCH_TAG: ${{ github.ref_name == 'experimental' && 'experimental' || '' }}
+  BRANCH_TAG: ${{ github.ref_name == 'experimental' && 'experimental' || github.ref_name == 'auth-server' && 'auth-server' || '' }}
 
 name: CI
 jobs:
@@ -136,6 +137,7 @@ jobs:
           AWS_ACCESS_KEY_ID: ${{ secrets.SDK_TEAM_AWS_ID }}
           AWS_SECRET_ACCESS_KEY: ${{ secrets.SDK_TEAM_AWS_SECRET }}
 
+
       - name: publish @dcl/ecs package
         uses: decentraland/oddish-action@master
         id: publish_ecs

Makefile

@@ -120,7 +120,7 @@ deep-clean:
 		packages/@dcl/ecs/node_modules/ \
 		packages/@dcl/react-ecs/node_modules/ \
 		packages/@dcl/sdk/node_modules/ \
-		packages/@dcl/sdk-commands/node_modules \
+		packages/@dcl/sdk-commands/node_modules
 	make clean
 
 update-snapshots: export UPDATE_SNAPSHOTS=true

packages/@dcl/ecs/src/components/index.ts

@@ -26,6 +26,7 @@ import {
   TouchScreenControlsComponentDefinitionExtended
 } from './extended/TouchScreenControls'
 import defineTagsComponent, { TagsComponentDefinitionExtended } from './manual/Tags'
+import defineCreatedBy, { ICreatedByType } from './manual/CreatedBy'
 
 export * from './generated/index.gen'
 
@@ -118,19 +119,24 @@ export const SyncComponents: (
 /**
  * @alpha
  */
-/* @__PURE__ */
 export const NetworkEntity: (
   engine: Pick<IEngine, 'defineComponent'>
 ) => LastWriteWinElementSetComponentDefinition<INetowrkEntityType> = (engine) => defineNetworkEntity(engine)
 
 /**
  * @alpha
  */
-/* @__PURE__ */
 export const NetworkParent: (
   engine: Pick<IEngine, 'defineComponent'>
 ) => LastWriteWinElementSetComponentDefinition<INetowrkParentType> = (engine) => defineNetworkParent(engine)
 
+/**
+ * @public
+ */
+export const CreatedBy: (
+  engine: Pick<IEngine, 'defineComponent'>
+) => LastWriteWinElementSetComponentDefinition<ICreatedByType> = (engine) => defineCreatedBy(engine)
+
 export { MediaState }
 
 export type { AudioAnalysisView }

packages/@dcl/ecs/src/components/manual/CreatedBy.ts

@@ -0,0 +1,17 @@
+import { IEngine, LastWriteWinElementSetComponentDefinition } from '../../engine/types'
+import { Schemas } from '../../schemas'
+
+export interface ICreatedByType {
+  address: string
+}
+
+export type ICreatedBy = LastWriteWinElementSetComponentDefinition<ICreatedByType>
+
+function defineCreatedBy(engine: Pick<IEngine, 'defineComponent'>) {
+  const CreatedBy = engine.defineComponent('core-schema::Created-By', {
+    address: Schemas.String
+  })
+  return CreatedBy
+}
+
+export default defineCreatedBy

packages/@dcl/ecs/src/components/manual/Transform.ts

@@ -35,7 +35,7 @@ export interface TransformComponentExtended extends TransformComponent {
 }
 
 /**
- * @internal
+ * @public
  */
 export const COMPONENT_ID = 1
 
@@ -49,10 +49,10 @@ export type TransformType = {
   parent?: Entity
 }
 
-/** @internal */
+/** @public */
 export const TRANSFORM_LENGTH = 44
 
-/** @internal */
+/** @public */
 export const TransformSchema: ISchema<TransformType> = {
   serialize(value: TransformType, builder: ByteBuffer): void {
     const ptr = builder.incrementWriteOffset(TRANSFORM_LENGTH)

packages/@dcl/ecs/src/components/types.ts

@@ -25,6 +25,7 @@ export type { TagsComponentDefinitionExtended, TagsType } from './manual/Tags'
 export type { ISyncComponents, ISyncComponentsType } from './manual/SyncComponents'
 export type { INetowrkEntity, INetowrkEntityType } from './manual/NetworkEntity'
 export type { INetowrkParent, INetowrkParentType } from './manual/NetworkParent'
+export type { ICreatedBy, ICreatedByType } from './manual/CreatedBy'
 export type { InputModifierHelper, InputModifierComponentDefinitionExtended } from './extended/InputModifier'
 export type { LightSourceHelper, LightSourceComponentDefinitionExtended } from './extended/LightSource'
 export type { TriggerAreaComponentDefinitionExtended } from './extended/TriggerArea'

packages/@dcl/ecs/src/engine/component.ts

@@ -1,6 +1,11 @@
 import { ISchema } from '../schemas'
 import { ByteBuffer } from '../serialization/ByteBuffer'
-import { CrdtMessageBody, DeleteComponentMessageBody, PutComponentMessageBody } from '../serialization/crdt'
+import {
+  CrdtMessageBody,
+  DeleteComponentMessageBody,
+  ProcessMessageResultType,
+  PutComponentMessageBody
+} from '../serialization/crdt'
 import { Entity } from './entity'
 import { DeepReadonly, DeepReadonlySet } from './readonly'
 
@@ -38,6 +43,14 @@ export interface BaseComponent<T> {
    * @public
    */
   updateFromCrdt(body: CrdtMessageBody): [null | ConflictResolutionMessage, T | undefined]
+  /**
+   * @internal
+   */
+  __forceUpdateFromCrdt(body: CrdtMessageBody): [null, T | undefined]
+  /**
+   * @internal
+   */
+  __dry_run_updateFromCrdt(body: CrdtMessageBody): ProcessMessageResultType
 
   /**
    * This function returns an iterable with all the CRDT updates that need to be
@@ -104,8 +117,87 @@ export interface BaseComponent<T> {
    * If the value is undefined, the component was deleted.
    */
   onChange(entity: Entity, cb: (value: T | undefined) => void): void
+
+  /**
+   * @public
+   *
+   */
+  validateBeforeChange(entity: Entity, cb: ValidateCallback<T>): void
+  validateBeforeChange(cb: ValidateCallback<T>): void
+  /**
+   * @internal
+   */
+  __run_validateBeforeChange(entity: Entity, newValue: T | undefined, senderAddress: string, createdBy: string): boolean
+
+  /**
+   * Get the CRDT state for an entity (serialized data and timestamp)
+   * @param entity - Entity to get the CRDT state for
+   * @returns Object with serialized data and timestamp, or null if entity doesn't have the component
+   * @public
+   */
+  getCrdtState(entity: Entity): { data: Uint8Array; timestamp: number } | null
+}
+
+/**
+ * Internal component interface that exposes all internal methods for SDK use
+ * This is not exposed to users, only for internal SDK operations
+ */
+export interface InternalBaseComponent<T> extends BaseComponent<T> {
+  // This interface inherits all methods from BaseComponent but makes the internal methods
+  // more accessible for SDK internal use. The main difference is that this interface
+  // is marked as @internal and can be used within the SDK package without exposing
+  // internal methods to end users.
+
+  // All the internal methods are already available through inheritance:
+  // - __forceUpdateFromCrdt
+  // - __dry_run_updateFromCrdt
+  // - __onChangeCallbacks
+  // - __run_validateBeforeChange
+  // - dirtyIterator
+  // - iterator
+
+  /**
+   * @public
+   * Force update component state regardless of timestamp - used for server authoritative messages
+   */
+  __forceUpdateFromCrdt(body: CrdtMessageBody): [null, T | undefined]
+
+  /**
+   * @public
+   * Dry run update to check if a CRDT message would be accepted without actually applying it
+   */
+  __dry_run_updateFromCrdt(body: CrdtMessageBody): ProcessMessageResultType
+
+  /**
+   * @public
+   * Get the iterator to every entity has the component
+   */
+  iterator(): Iterable<[Entity, any]>
+
+  /**
+   * @public
+   */
+  dirtyIterator(): Iterable<Entity>
+
+  /**
+   * @public
+   */
+  __onChangeCallbacks(entity: Entity, value: T): void
+
+  /**
+   * @public
+   */
+  __run_validateBeforeChange(entity: Entity, newValue: T | undefined, senderAddress: string, createdBy: string): boolean
 }
 
+export type ValidateCallback<T> = (value: {
+  entity: Entity // The entity being validated
+  currentValue: T | undefined // Current value of the component (undefined if component doesn't exist)
+  newValue: T | undefined // New value being set (undefined if component is being deleted)
+  senderAddress: string // Peer address/sender of the change
+  createdBy: string // Address of the user who created the change
+}) => boolean
+
 /**
  * @public
  */
@@ -211,6 +303,14 @@ export interface GrowOnlyValueSetComponentDefinition<T> extends BaseComponent<T>
    * @returns
    */
   get(entity: Entity): DeepReadonlySet<T>
+
+  /**
+   * Get the CRDT state for an entity (serialized data and timestamp)
+   * @param entity - Entity to get the CRDT state for
+   * @returns Object with serialized data and timestamp, or null if entity doesn't have the component
+   * @internal
+   */
+  getCrdtState(entity: Entity): { data: Uint8Array; timestamp: number } | null
 }
 
 /**

packages/@dcl/ecs/src/engine/grow-only-value-set-component-definition.ts

@@ -1,12 +1,18 @@
 import { ISchema } from '../schemas'
 import { ReadWriteByteBuffer } from '../serialization/ByteBuffer'
-import { AppendValueMessageBody, AppendValueOperation, CrdtMessageType } from '../serialization/crdt'
-import { ComponentType, GrowOnlyValueSetComponentDefinition } from './component'
+import {
+  AppendValueMessageBody,
+  AppendValueOperation,
+  CrdtMessageType,
+  ProcessMessageResultType
+} from '../serialization/crdt'
+import { ComponentType, GrowOnlyValueSetComponentDefinition, ValidateCallback } from './component'
 import { __DEV__ } from '../runtime/invariant'
 import { Entity } from './entity'
 import { DeepReadonly, DeepReadonlySet } from './readonly'
 
 const emptyReadonlySet = freezeSet(new Set())
+const __GLOBAL_ENTITY = '__GLOBAL_ENTITY' as any as Entity
 
 function frozenError() {
   throw new Error('The set is frozen')
@@ -50,6 +56,7 @@ export function createValueSetComponentDefinitionFromSchema<T>(
   const dirtyIterator = new Set<Entity>()
   const queuedCommands: AppendValueMessageBody[] = []
   const onChangeCallbacks = new Map<Entity, ((data: T | undefined) => void)[]>()
+  const validateCallbacks = new Map<Entity, ValidateCallback<T>>()
 
   // only sort the array if the latest (N) element has a timestamp <= N-1
   function shouldSort(row: InternalDatastructure) {
@@ -111,8 +118,11 @@ export function createValueSetComponentDefinitionFromSchema<T>(
     has(entity: Entity): boolean {
       return data.has(entity)
     },
-    entityDeleted(entity: Entity): void {
+    entityDeleted(entity: Entity, markAsDirty: boolean): void {
       data.delete(entity)
+      if (markAsDirty) {
+        // For grow-only sets, we don't need to mark as dirty since deletion doesn't generate CRDT messages
+      }
     },
     get(entity: Entity): DeepReadonlySet<T> {
       const values = data.get(entity)
@@ -180,6 +190,47 @@ export function createValueSetComponentDefinitionFromSchema<T>(
       for (const cb of cbs) {
         cb(value)
       }
+    },
+    __dry_run_updateFromCrdt(_body) {
+      return ProcessMessageResultType.StateUpdatedData
+    },
+    validateBeforeChange(entityOrCb: Entity | ValidateCallback<T>, cb?: ValidateCallback<T>): void {
+      if (arguments.length === 1) {
+        // Second overload: just callback (global validation)
+        validateCallbacks.set(__GLOBAL_ENTITY, entityOrCb as ValidateCallback<T>)
+      } else {
+        if (cb) {
+          validateCallbacks.set(entityOrCb as Entity, cb)
+        }
+      }
+    },
+    __run_validateBeforeChange(entity, newValue, senderAddress, createdBy): boolean {
+      const cb = entity && validateCallbacks.get(entity)
+      const globalCb = validateCallbacks.get(__GLOBAL_ENTITY)
+      const currentValue = [...this.get(entity).values()]
+
+      const value = { entity, currentValue: currentValue as T, newValue, senderAddress, createdBy }
+
+      const globalResult = globalCb?.(value) ?? true
+      const entityResult = (globalResult && cb?.(value)) ?? true
+
+      return globalResult && entityResult
+    },
+    getCrdtState(entity: Entity): { data: Uint8Array; timestamp: number } | null {
+      const row = data.get(entity)
+      if (!row || row.raw.length === 0) {
+        return null
+      }
+
+      // For GrowOnlySet, we need to return the complete CRDT messages for all values
+      // This is complex because GrowOnlySet uses APPEND messages, not a single PUT
+      // For now, return null to indicate this component type doesn't support simple corrections
+      return null
+    },
+    __forceUpdateFromCrdt(_msg) {
+      // GrowOnlySet doesn't support authoritative corrections in the same way as LWW
+      // since it uses APPEND_VALUE messages instead of PUT_COMPONENT messages
+      return [null, undefined]
     }
   }