mysql

README

MySQL 存储 for [OAuth 2.0]信息(https://github.com/go-oauth2/oauth2)

说明

只是一个go-oauth2-mysql的升级版，将作者v3升级到了v4，作用是，将client存储到mysql里，不用存储在内存，具体实现可以看源码

自定义

可以自己写一个存储，源码里给了思路

Install

$ go get gitee.com/w1134407270/go-oauth2-mysql-v4

MySQL drivers

这个存储采用 sqlx.DB 来连接数据库 . sqlx.DB 的实现来自 github.com/jmoiron/sqlx

使用例子

package main

import (
	_ "github.com/go-sql-driver/mysql"
	mysql "gitee.com/w1134407270/go-oauth2-mysql-v4"
	"github.com/jmoiron/sqlx"
)

func main() {
	db, err := sqlx.Connect("mysql", "user:password@tcp(127.0.0.1:3306)/oauth_db?parseTime=true")
	if err != nil {
		log.Fatalln(err)
	}

	clientStore, _ := mysql.NewClientStore(db, mysql.WithClientStoreTableName("custom_table_name"))
	tokenStore, _ := mysql.NewTokenStore(db)
}

怎么测试

docker下可以使用以下实例

$ docker run -it  -p 3306:3306 -e MYSQL_ROOT_PASSWORD=oauth2 -d mysql
$ docker exec -it <container_id> bash
$ mysql -u root -poauth2
> create database oauth_db

$ MYSQL_URI=root:oauth2@tcp(127.0.0.1:3306)/oauth_db?parseTime=true go test .

MIT License 开源协议

Copyright (c) 2021 Imre Nagi

Credits

• Oauth Postgres Implementation github.com/vgarvardt/go-pg-adapter

Documentation

Index

• type ClientStore
  • func NewClientStore(db *sqlx.DB, options ...ClientStoreOption) (*ClientStore, error)
  • func (s *ClientStore) Create(info oauth2.ClientInfo) error
  • func (s *ClientStore) GetByID(ctx context.Context, id string) (oauth2.ClientInfo, error)
• type ClientStoreItem
• type ClientStoreOption
  • func WithClientStoreInitTableDisabled() ClientStoreOption
  • func WithClientStoreTableName(tableName string) ClientStoreOption
• type TokenStore
  • func NewTokenStore(db *sqlx.DB, options ...TokenStoreOption) (*TokenStore, error)
  • func (s *TokenStore) Close() error
  • func (s *TokenStore) Create(info oauth2.TokenInfo) error
  • func (s *TokenStore) GetByAccess(access string) (oauth2.TokenInfo, error)
  • func (s *TokenStore) GetByCode(code string) (oauth2.TokenInfo, error)
  • func (s *TokenStore) GetByRefresh(refresh string) (oauth2.TokenInfo, error)
  • func (s *TokenStore) RemoveByAccess(access string) error
  • func (s *TokenStore) RemoveByCode(code string) error
  • func (s *TokenStore) RemoveByRefresh(refresh string) error
• type TokenStoreItem
• type TokenStoreOption
  • func WithTokenStoreGCDisabled() TokenStoreOption
  • func WithTokenStoreGCInterval(gcInterval time.Duration) TokenStoreOption
  • func WithTokenStoreInitTableDisabled() TokenStoreOption
  • func WithTokenStoreTableName(tableName string) TokenStoreOption

Types

type ClientStore

type ClientStore struct {
	// contains filtered or unexported fields
}

func NewClientStore

func NewClientStore(db *sqlx.DB, options ...ClientStoreOption) (*ClientStore, error)

NewClientStore creates PostgreSQL store instance

func (*ClientStore) Create

func (s *ClientStore) Create(info oauth2.ClientInfo) error

Create creates and stores the new client information

func (*ClientStore) GetByID

func (s *ClientStore) GetByID(ctx context.Context, id string) (oauth2.ClientInfo, error)

GetByID retrieves and returns client information by id

type ClientStoreItem

type ClientStoreItem struct {
	ID     string `db:"id"`
	Secret string `db:"secret"`
	Domain string `db:"domain"`
	Data   string `db:"data"`
}

ClientStoreItem data item

type ClientStoreOption

type ClientStoreOption func(s *ClientStore)

ClientStoreOption is the configuration options type for client store

func WithClientStoreInitTableDisabled

func WithClientStoreInitTableDisabled() ClientStoreOption

WithClientStoreInitTableDisabled returns option that disables table creation on client store instantiation

func WithClientStoreTableName

func WithClientStoreTableName(tableName string) ClientStoreOption

WithClientStoreTableName returns option that sets client store table name

type TokenStore

type TokenStore struct {
	// contains filtered or unexported fields
}

func NewTokenStore

func NewTokenStore(db *sqlx.DB, options ...TokenStoreOption) (*TokenStore, error)

NewTokenStore creates PostgreSQL store instance

func (*TokenStore) Close

func (s *TokenStore) Close() error

Close close the store

func (*TokenStore) Create

func (s *TokenStore) Create(info oauth2.TokenInfo) error

Create create and store the new token information

func (*TokenStore) GetByAccess

func (s *TokenStore) GetByAccess(access string) (oauth2.TokenInfo, error)

GetByAccess use the access token for token information data

func (*TokenStore) GetByCode

func (s *TokenStore) GetByCode(code string) (oauth2.TokenInfo, error)

GetByCode use the authorization code for token information data

func (*TokenStore) GetByRefresh

func (s *TokenStore) GetByRefresh(refresh string) (oauth2.TokenInfo, error)

GetByRefresh use the refresh token for token information data

func (*TokenStore) RemoveByAccess

func (s *TokenStore) RemoveByAccess(access string) error

RemoveByAccess use the access token to delete the token information

func (*TokenStore) RemoveByCode

func (s *TokenStore) RemoveByCode(code string) error

RemoveByCode delete the authorization code

func (*TokenStore) RemoveByRefresh

func (s *TokenStore) RemoveByRefresh(refresh string) error

RemoveByRefresh use the refresh token to delete the token information

type TokenStoreItem

type TokenStoreItem struct {
	ID        int64     `db:"id"`
	CreatedAt time.Time `db:"created_at"`
	ExpiredAt time.Time `db:"expired_at"`
	Code      string    `db:"code"`
	Access    string    `db:"access"`
	Refresh   string    `db:"refresh"`
	Data      string    `db:"data"`
}

TokenStoreItem data item

type TokenStoreOption

type TokenStoreOption func(s *TokenStore)

TokenStoreOption is the configuration options type for token store

func WithTokenStoreGCDisabled

func WithTokenStoreGCDisabled() TokenStoreOption

WithTokenStoreGCDisabled returns option that disables token store garbage collection

func WithTokenStoreGCInterval

func WithTokenStoreGCInterval(gcInterval time.Duration) TokenStoreOption

WithTokenStoreGCInterval returns option that sets token store garbage collection interval

func WithTokenStoreInitTableDisabled

func WithTokenStoreInitTableDisabled() TokenStoreOption

WithTokenStoreInitTableDisabled returns option that disables table creation on token store instantiation

func WithTokenStoreTableName

func WithTokenStoreTableName(tableName string) TokenStoreOption

WithTokenStoreTableName returns option that sets token store table name