( ctx context.Context, s gomatrixserverlib.ServerName, oneTimeKeys map[string]map[string]string, )
| 40 | } |
| 41 | |
| 42 | func (a *FederationInternalAPI) ClaimKeys( |
| 43 | ctx context.Context, s gomatrixserverlib.ServerName, oneTimeKeys map[string]map[string]string, |
| 44 | ) (gomatrixserverlib.RespClaimKeys, error) { |
| 45 | ctx, cancel := context.WithTimeout(ctx, time.Second*30) |
| 46 | defer cancel() |
| 47 | ires, err := a.doRequestIfNotBackingOffOrBlacklisted(s, func() (interface{}, error) { |
| 48 | return a.federation.ClaimKeys(ctx, s, oneTimeKeys) |
| 49 | }) |
| 50 | if err != nil { |
| 51 | return gomatrixserverlib.RespClaimKeys{}, err |
| 52 | } |
| 53 | return ires.(gomatrixserverlib.RespClaimKeys), nil |
| 54 | } |
| 55 | |
| 56 | func (a *FederationInternalAPI) QueryKeys( |
| 57 | ctx context.Context, s gomatrixserverlib.ServerName, keys map[string][]string, |
nothing calls this directly
no test coverage detected