mirror of
https://github.com/hanzoai/forge.git
synced 2026-10-30 15:00:39 +00:00
zeekayandHanzo Dev
cd157b5a8a
binding, captcha, cache and session came from gitea.com/go-chi — Gitea forks of
Martini/Macaron middleware, ~6000 LOC across 27 files. They are in-tree now:
modules/binding (23 consumers repointed)
modules/captcha
modules/cache/chi (modules/cache already ours; upstream goes beneath)
modules/session/chi
Not a zip migration, and that is deliberate. zip has no session layer and no
captcha layer — this forge authenticates every web request through a session,
so porting to zip is not a port, it is an auth rewrite. Vendoring removes the
gitea.com dependency, which is what was actually being asked for, at zero risk
to the auth path. The zip migration stays available and is now a decision about
the router alone rather than one entangled with sessions.
Trimmed while vendoring:
- session/ledis, cache/{ledis,nodb} deleted. The supported providers are
memory/file/kv/mysql/postgres/couchbase/memcache/db, so those backends were
dead code dragging ledisdb and nodb into the module graph.
- backend tests needing a live memcache/mysql/postgres/couchbase/redis
removed. They had never run here (they lived in an external module) and
would have been red forever. The hermetic memory/file/session tests stay
and pass.
Remaining gitea.com deps are three real upstream projects, not middleware:
runner, dingtalk_webhook, levelqueue.
Everything green; integration compile gate green.
Co-authored-by: Hanzo Dev <[email protected]>
121 lines
2.9 KiB
Go
121 lines
2.9 KiB
Go
// Copyright 2026 Hanzo AI, Inc. All rights reserved.
|
|
// Copyright 2017 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package cache
|
|
|
|
import (
|
|
"encoding/hex"
|
|
"errors"
|
|
"fmt"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/hanzoai/git/modules/setting"
|
|
|
|
_ "github.com/hanzoai/git/modules/cache/chi/memcache" //nolint:depguard // memcache plugin for cache, it is required for config "ADAPTER=memcache"
|
|
)
|
|
|
|
var defaultCache StringCache
|
|
|
|
// Init start cache service
|
|
func Init() error {
|
|
if defaultCache == nil {
|
|
c, err := NewStringCache(setting.CacheService.Cache)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
for range 10 {
|
|
if err = c.Ping(); err == nil {
|
|
break
|
|
}
|
|
time.Sleep(time.Second)
|
|
}
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defaultCache = c
|
|
}
|
|
return nil
|
|
}
|
|
|
|
const (
|
|
testCacheKey = "DefaultCache.TestKey"
|
|
// SlowCacheThreshold marks cache tests as slow
|
|
// set to 30ms per discussion: https://github.com/go-gitea/gitea/issues/33190
|
|
// TODO: Replace with metrics histogram
|
|
SlowCacheThreshold = 30 * time.Millisecond
|
|
)
|
|
|
|
// Test performs delete, put and get operations on a predefined key
|
|
// returns
|
|
func Test() (time.Duration, error) {
|
|
if defaultCache == nil {
|
|
return 0, errors.New("default cache not initialized")
|
|
}
|
|
|
|
testData := hex.EncodeToString(make([]byte, 500))
|
|
|
|
start := time.Now()
|
|
|
|
if err := defaultCache.Delete(testCacheKey); err != nil {
|
|
return 0, fmt.Errorf("expect cache to delete data based on key if exist but got: %w", err)
|
|
}
|
|
if err := defaultCache.Put(testCacheKey, testData, 10); err != nil {
|
|
return 0, fmt.Errorf("expect cache to store data but got: %w", err)
|
|
}
|
|
testVal, hit := defaultCache.Get(testCacheKey)
|
|
if !hit {
|
|
return 0, errors.New("expect cache hit but got none")
|
|
}
|
|
if testVal != testData {
|
|
return 0, errors.New("expect cache to return same value as stored but got other")
|
|
}
|
|
|
|
return time.Since(start), nil
|
|
}
|
|
|
|
// GetCache returns the currently configured cache
|
|
func GetCache() StringCache {
|
|
return defaultCache
|
|
}
|
|
|
|
// GetString returns the key value from cache with callback when no key exists in cache
|
|
func GetString(key string, getFunc func() (string, error)) (string, error) {
|
|
if defaultCache == nil || setting.CacheService.TTL == 0 {
|
|
return getFunc()
|
|
}
|
|
cached, exist := defaultCache.Get(key)
|
|
if !exist {
|
|
value, err := getFunc()
|
|
if err != nil {
|
|
return value, err
|
|
}
|
|
return value, defaultCache.Put(key, value, setting.CacheService.TTLSeconds())
|
|
}
|
|
return cached, nil
|
|
}
|
|
|
|
// GetInt64 returns key value from cache with callback when no key exists in cache
|
|
func GetInt64(key string, getFunc func() (int64, error)) (int64, error) {
|
|
s, err := GetString(key, func() (string, error) {
|
|
v, err := getFunc()
|
|
return strconv.FormatInt(v, 10), err
|
|
})
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
if s == "" {
|
|
return 0, nil
|
|
}
|
|
return strconv.ParseInt(s, 10, 64)
|
|
}
|
|
|
|
// Remove key from cache
|
|
func Remove(key string) {
|
|
if defaultCache == nil {
|
|
return
|
|
}
|
|
_ = defaultCache.Delete(key)
|
|
}
|