cache.go
No OneTemporary
Actions

Size

1 KB

Subscribers

None

cache.go
View Options

	/*
	* Copyright © 2018 A Bunch Tell LLC.
	*
	* This file is part of WriteFreely.
	*
	* WriteFreely is free software: you can redistribute it and/or modify
	* it under the terms of the GNU Affero General Public License, included
	* in the LICENSE file in this source code package.
	*/

	package writefreely

	import (
	"sync"
	"time"
	)

	const (
	postsCacheTime = 4 * time.Second
	)

	type (
	postsCacheItem struct {
	Expire time.Time
	Posts *[]PublicPost
	ready chan struct{}
	}

	AuthCache struct {
	Alias, Pass, Token string
	BadPasses map[string]bool

	expire time.Time
	}
	)

	var (
	userPostsCache = struct {
	sync.RWMutex
	users map[int64]postsCacheItem
	}{
	users: map[int64]postsCacheItem{},
	}
	)

	func CachePosts(userID int64, p *[]PublicPost) {
	close(userPostsCache.users[userID].ready)
	userPostsCache.Lock()
	userPostsCache.users[userID] = postsCacheItem{
	Expire: time.Now().Add(postsCacheTime),
	Posts: p,
	}
	userPostsCache.Unlock()
	}

	func GetPostsCache(userID int64) *[]PublicPost {
	userPostsCache.RLock()
	pci, ok := userPostsCache.users[userID]
	userPostsCache.RUnlock()
	if !ok {
	return nil
	}

	if pci.Expire.Before(time.Now()) {
	// Cache is expired
	return nil
	}
	return pci.Posts
	}