mirror of
https://github.com/openziti/zrok.git
synced 2025-06-26 12:42:18 +02:00
secrets retrieval lint, controller-side (#983)
This commit is contained in:
parent
9f89126e9e
commit
332400d34f
@ -47,5 +47,27 @@ type secretsGrpcImpl struct {
|
|||||||
|
|
||||||
func (i *secretsGrpcImpl) FetchSecrets(_ context.Context, req *secretsGrpc.SecretsRequest) (*secretsGrpc.SecretsResponse, error) {
|
func (i *secretsGrpcImpl) FetchSecrets(_ context.Context, req *secretsGrpc.SecretsRequest) (*secretsGrpc.SecretsResponse, error) {
|
||||||
logrus.Infof("request for secrets for '%v'", req.ShareToken)
|
logrus.Infof("request for secrets for '%v'", req.ShareToken)
|
||||||
return nil, nil
|
|
||||||
|
trx, err := str.Begin()
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
defer trx.Rollback()
|
||||||
|
|
||||||
|
shr, err := str.FindShareWithToken(req.ShareToken, trx)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
secrets, err := str.GetSecrets(shr.Id, trx)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
out := &secretsGrpc.SecretsResponse{}
|
||||||
|
for _, secret := range secrets.Secrets {
|
||||||
|
out.Secrets = append(out.Secrets, &secretsGrpc.Secret{Key: secret.Key, Value: secret.Value})
|
||||||
|
}
|
||||||
|
|
||||||
|
return out, nil
|
||||||
}
|
}
|
||||||
|
@ -32,7 +32,7 @@ func (str *Store) CreateSecrets(secrets Secrets, trx *sqlx.Tx) error {
|
|||||||
|
|
||||||
func (str *Store) GetSecrets(shareId int, trx *sqlx.Tx) (Secrets, error) {
|
func (str *Store) GetSecrets(shareId int, trx *sqlx.Tx) (Secrets, error) {
|
||||||
secrets := Secrets{}
|
secrets := Secrets{}
|
||||||
rows, err := trx.Queryx("select * from secrets where share_id = $1 and not deleted", shareId)
|
rows, err := trx.Queryx("select key, value from secrets where share_id = $1 and not deleted", shareId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return Secrets{}, errors.Wrap(err, "error getting all from secrets")
|
return Secrets{}, errors.Wrap(err, "error getting all from secrets")
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user