Method withWriteLock

pkg/memory/database/sqlite/sqlite.go:103–115

(ctx context.Context, fn func(*sql.DB) error)

}

func (m *MemoryDatabase) withWriteLock(ctx context.Context, fn func(*sql.DB) error) error {
	db, err := m.ensureDB(ctx)
	if err != nil {
		return err
	}

	lock := database.NewFileLock(m.lockPath)
	if err := lock.Lock(ctx); err != nil {
		return err
	}
	defer func() { _ = lock.Unlock() }()
	return fn(db)
}

func (m *MemoryDatabase) AddMemory(ctx context.Context, memory database.UserMemory) error {
	ctx, span := startMemorySpan(ctx, "add")