adding ability to force refresh source credential.

clients/internal/base/base_client.go

@@ -114,12 +114,17 @@ func (c *SourceClientBase) GetSourceCredential() models.SourceCredential {
  return c.SourceCredential
 }
 
-func (c *SourceClientBase) RefreshAccessToken() error {
+func (c *SourceClientBase) RefreshAccessToken(options ...func(*models.SourceClientRefreshOptions)) error {
  if c.testMode {
  //if test mode is enabled, we cannot refresh the access token
  return nil
  }
 
+ refreshOptions := &models.SourceClientRefreshOptions{}
+ for _, o := range options {
+ o(refreshOptions)
+ }
+
  c.refreshMutex.Lock()
  defer c.refreshMutex.Unlock()
 
@@ -144,8 +149,12 @@ func (c *SourceClientBase) RefreshAccessToken() error {
  Expiry: time.Unix(c.SourceCredential.GetExpiresAt(), 0),
  }
 
- if token.Expiry.Before(time.Now().Add(5 * time.Second)) { // expired (or will expire in 5 seconds) so let's update it
- c.Logger.Info("access token expired, must refresh")
+ if refreshOptions.Force || token.Expiry.Before(time.Now().Add(5*time.Second)) { // expired (or will expire in 5 seconds) so let's update it
+ if refreshOptions.Force {
+ c.Logger.Info("force refresh access token", refreshOptions.Force)
+ } else {
+ c.Logger.Info("access token expired, must refresh")
+ }
 
  if c.SourceCredential.IsDynamicClient() {
  c.Logger.Info("refreshing dynamic client...")

clients/internal/manual/client.go

@@ -250,7 +250,7 @@ func (m ManualClient) ExtractPatientId(bundleFile *os.File) (string, pkg.FhirVer
  }
 }
 
-func (m ManualClient) RefreshAccessToken() error {
+func (m ManualClient) RefreshAccessToken(options ...func(*models.SourceClientRefreshOptions)) error {
  //TODO implement me
  panic("implement me")
 }

clients/models/source_client.go

@@ -19,5 +19,5 @@ type SourceClient interface {
  ExtractPatientId(bundleFile *os.File) (string, pkg.FhirVersion, error)
 
  GetSourceCredential() SourceCredential
- RefreshAccessToken() error
+ RefreshAccessToken(options ...func(*SourceClientRefreshOptions)) error
 }

clients/models/source_client_refresh_options.go

@@ -0,0 +1,11 @@
+package models
+
+type SourceClientRefreshOptions struct {
+ Force bool //force refresh even if token is not expired
+}
+
+func WithForce(force bool) func(*SourceClientRefreshOptions) {
+ return func(s *SourceClientRefreshOptions) {
+ s.Force = force
+ }
+}