Method Apply

sdks/csharp/src/Table.cs:448–524

Applies the parsed table update (delta) to this table. This updates the internal data structures and indices, but does not invoke user callbacks. Should be called before PostApply, after PreApply.

(IEventContext context, IParsedTableUpdate parsedTableUpdate)

        /// Should be called before PostApply, after PreApply.
        /// </summary>
        void IRemoteTableHandle.Apply(IEventContext context, IParsedTableUpdate parsedTableUpdate)
        {
            var delta = (ParsedTableUpdate)parsedTableUpdate;

            if (IsEventTable)
            {
                // Event tables: don't store rows in the cache or update indices.
                // Just collect the event rows so PostApply can fire OnInsert callbacks.
                if (delta.EventRows != null)
                {
                    foreach (var row in delta.EventRows)
                    {
                        wasInserted.Add(new KeyValuePair<object, Row>(row, row));
                    }
                }
                return;
            }

            try
            {
                Entries.Apply(delta.Delta, wasInserted, wasUpdated, wasRemoved);
            }
            catch (Exception e)
            {
                var deltaString = parsedTableUpdate.ToString();
                deltaString = deltaString[..Math.Min(deltaString.Length, 10_000)];
                var entriesString = Entries.ToString();
                entriesString = entriesString[..Math.Min(entriesString.Length, 10_000)];
                throw new Exception($"While table `{RemoteTableName}` was applying:\n{deltaString} \nto:\n{entriesString}", e);
            }

            // Update indices.
            // This is a local operation -- it only looks at our indices and doesn't invoke user code.
            // So we don't need to wait for other tables to be updated to do it.
            // (And we need to do it before any PostApply is called.)
            // Reminder: We need to loop through the removed entries to delete them prior to inserting the new entries,
            // in order to avoid keys an error with the same key already added.
            foreach (var (_, value) in wasRemoved)
            {
                if (value is Row oldRow)
                {
                    OnInternalDeleteHandler.Invoke(oldRow);
                }
            }
            foreach (var (_, value) in wasInserted)
            {
                if (value is Row newRow)
                {
                    OnInternalInsertHandler.Invoke(newRow);
                }
                else
                {
                    throw new Exception($"Invalid row type for table {RemoteTableName}: {value.GetType().Name}");
                }
            }
            foreach (var (_, oldValue, newValue) in wasUpdated)
            {
                if (oldValue is Row oldRow)