diff --git a/sqlite/dial.go b/sqlite/dial.go index 30fb852..007358b 100644 --- a/sqlite/dial.go +++ b/sqlite/dial.go @@ -370,9 +370,11 @@ func createDial(ctx context.Context, tx *Tx, dial *wtf.Dial) error { dial.CreatedAt = tx.now dial.UpdatedAt = dial.CreatedAt - // Perform basic field validation. + // Perform basic field validation & ensure user exists. if err := dial.Validate(); err != nil { return err + } else if _, err := findUserByID(ctx, tx, dial.UserID); err != nil { + return err } // Insert row into database.