Method CommitCtx

pkg/sqlite3store/sqlite3store.go:89–112

CommitCtx adds a session token and data to the SQLite3Store instance with the given expiry time. If the session token already exists, then the data and expiry time are updated.

(ctx context.Context, token string, b []byte, expiry time.Time)

// given expiry time. If the session token already exists, then the data and expiry
// time are updated.
func (p *SQLite3Store) CommitCtx(ctx context.Context, token string, b []byte, expiry time.Time) error {
	tx, err := p.db.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer func() { _ = tx.Rollback() }()

	_, err = tx.ExecContext(ctx, `
		INSERT INTO sessions (token, data, expiry)
		VALUES (?, ?, ?)
		ON CONFLICT(token) DO UPDATE SET
			data = excluded.data,
			expiry = excluded.expiry
	`, token, b, toJulianDay(expiry.UTC()))
	if err != nil {
		return err
	}

	if err = tx.Commit(); err != nil {
		return err
	}

	return nil
}

// Delete removes a session token and corresponding data from the SQLite3Store
// instance.