insertWaitingMessages method

Future<void> insertWaitingMessages(
  1. List<WaitingMessage> messages
)

Implementation

Future<void> insertWaitingMessages(List<WaitingMessage> messages) async {
  final batch = _database.batch();

  for (final message in messages) {
    batch.insert(
      tableName,
      {
        columnId: message.id,
        columnTimestamp: message.timestamp,
        columnEvent: message.event,
        columnChannel: message.channel,
        columnPayload: message.payload.toString(),
        columnFinalPayload: message.getFinalPayload().toString(),
        columnResolved: message.resolved ? 1 : 0,
        columnFailed: message.failed ? 1 : 0,
      },
    );
  }

  await batch.commit(noResult: true);
}