enqueuePendingOp method

Implementation

@override
Future<void> enqueuePendingOp(store.PendingOp<T, Id> op) async {
  await db
      .into(db.pendingOps)
      .insert(
        PendingOpsCompanion.insert(
          opId: op.opId,
          scopeName: op.scope.name,
          scopeKeys: _scopeKey(op.scope),
          type: op.type.name,
          id: idToString(op.id),
          payload: d.Value(
            op.payload == null ? null : jsonEncode(toJson(op.payload as T)),
          ),
          updatedAt: op.updatedAt.toIso8601String(),
        ),
        mode: d.InsertMode.insertOrAbort,
      );
}