decoding stuff

pkg/core/db/sql/migrations/00015_entity_tables.sql

@@ -0,0 +1,21 @@
+-- +migrate Up
+create table if not exists core_plays(
+    rowid serial primary key,
+    user_id text not null,
+    track_id text not null,
+
+    -- future fields
+    listener_address text not null,
+    cid text not null,
+
+    city text not null,
+    country text not null,
+    region text not null,
+    signer text not null,
+    signature text not null,
+    block bigint not null,
+    created_at timestamptz not null
+)
+
+-- +migrate Down
+drop table if exists core_plays;

pkg/core/db/sql/writes.sql

@@ -63,3 +63,7 @@ where block_height = $3 and address = $4;
 -- name: InsertFailedStorageProof :exec
 insert into storage_proofs (block_height, address, status)
 values ($1, $2, 'fail');
+
+-- name: InsertPlayRecord :exec
+insert into core_plays (user_id, track_id, listener_address, cid, city, country, region, signer, signature, block, created_at)
+values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11) on conflict do nothing;

pkg/core/server/plays.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 
+	"github.com/AudiusProject/audiusd/pkg/core/db"
 	"github.com/AudiusProject/audiusd/pkg/core/gen/core_proto"
 )
 
@@ -22,5 +23,15 @@ func (s *Server) finalizePlayTransaction(ctx context.Context, stx *core_proto.Si
 		return nil, errors.New("invalid play tx")
 	}
 
+	for _, play := range tx.Plays {
+		if err := s.getDb().InsertPlayRecord(ctx, db.InsertPlayRecordParams{
+			TrackID: tx.,
+			UserID:  tx.UserId,
+		}); err != nil {
+			s.logger.Errorf("error inserting play record: %v", err)
+		}
+
+	}
+
 	return tx, nil
 }