(ctx context.Context, event *telemetrydata.TEvent)
| 127 | } |
| 128 | |
| 129 | func insertTEvent(ctx context.Context, event *telemetrydata.TEvent) error { |
| 130 | if event.Uuid == "" { |
| 131 | return fmt.Errorf("cannot insert TEvent: uuid is empty") |
| 132 | } |
| 133 | if event.Ts == 0 { |
| 134 | return fmt.Errorf("cannot insert TEvent: ts is 0") |
| 135 | } |
| 136 | if event.TsLocal == "" { |
| 137 | return fmt.Errorf("cannot insert TEvent: tslocal is empty") |
| 138 | } |
| 139 | if event.Event == "" { |
| 140 | return fmt.Errorf("cannot insert TEvent: event is empty") |
| 141 | } |
| 142 | return wstore.WithTx(ctx, func(tx *wstore.TxWrap) error { |
| 143 | query := `INSERT INTO db_tevent (uuid, ts, tslocal, event, props) |
| 144 | VALUES (?, ?, ?, ?, ?)` |
| 145 | tx.Exec(query, event.Uuid, event.Ts, event.TsLocal, event.Event, dbutil.QuickJson(event.Props)) |
| 146 | return nil |
| 147 | }) |
| 148 | } |
| 149 | |
| 150 | // merges newActivity into curActivity, returns curActivity |
| 151 | func mergeActivity(curActivity *telemetrydata.TEventProps, newActivity telemetrydata.TEventProps) { |
no test coverage detected