Make sure the channel event UUID is generated and read from the the DB

Author: norkans7

Diff for: backends/rapidpro/backend_test.go

@@ -1641,7 +1641,7 @@ WHERE
 `
 
 const sqlSelectEvent = `
-SELECT id, org_id, channel_id, contact_id, contact_urn_id, event_type, optin_id, extra, occurred_on, created_on, log_uuids
+SELECT id, uuid, org_id, channel_id, contact_id, contact_urn_id, event_type, optin_id, extra, occurred_on, created_on, log_uuids
   FROM channels_channelevent
  WHERE id = $1`
 

Diff for: backends/rapidpro/channel_event.go

@@ -14,6 +14,7 @@ import (
 	"github.com/lib/pq"
 	"github.com/nyaruka/courier"
 	"github.com/nyaruka/gocommon/urns"
+	"github.com/nyaruka/gocommon/uuids"
 	"github.com/nyaruka/null/v3"
 )
 
@@ -65,6 +66,7 @@ func newChannelEvent(channel courier.Channel, eventType courier.ChannelEventType
 	dbChannel := channel.(*Channel)
 
 	return &ChannelEvent{
+		UUID_:        courier.ChannelEventUUID(uuids.NewV4()),
 		ChannelUUID_: dbChannel.UUID_,
 		OrgID_:       dbChannel.OrgID_,
 		ChannelID_:   dbChannel.ID_,
@@ -136,8 +138,8 @@ func writeChannelEvent(ctx context.Context, b *backend, event courier.ChannelEve
 
 const sqlInsertChannelEvent = `
 INSERT INTO 
-	channels_channelevent( org_id,  channel_id,  contact_id,  contact_urn_id,  event_type,  optin_id,  extra,  occurred_on, created_on, status,  log_uuids)
-				   VALUES(:org_id, :channel_id, :contact_id, :contact_urn_id, :event_type, :optin_id, :extra, :occurred_on,      NOW(), 'P',    :log_uuids)
+	channels_channelevent( org_id,  uuid,  channel_id,  contact_id,  contact_urn_id,  event_type,  optin_id,  extra,  occurred_on, created_on, status,  log_uuids)
+				   VALUES(:org_id, :uuid, :channel_id, :contact_id, :contact_urn_id, :event_type, :optin_id, :extra, :occurred_on,      NOW(), 'P',    :log_uuids)
 RETURNING id, created_on`
 
 // writeChannelEventToDB writes the passed in channel event to our db

Diff for: backends/rapidpro/schema.sql

@@ -129,6 +129,7 @@ CREATE TABLE channels_channellog (
 DROP TABLE IF EXISTS channels_channelevent CASCADE;
 CREATE TABLE channels_channelevent (
     id serial primary key,
+    uuid uuid NOT NULL,
     event_type character varying(16) NOT NULL,
     status character varying(1) NOT NULL,
     extra text,