1 package org.influxdb.impl;
2
3 import java.io.IOException;
4
5 import okhttp3.Credentials;
6 import okhttp3.Interceptor;
7 import okhttp3.Request;
8 import okhttp3.Response;
9
10 public class BasicAuthInterceptor implements Interceptor {
11
12   private String credentials;
13
14   public BasicAuthInterceptor(final String user, final String password) {
15     credentials = Credentials.basic(user, password);
16   }
17
18   @Override
19   public Response intercept(final Chain chain) throws IOException {
20     Request request = chain.request();
21     Request authenticatedRequest = request.newBuilder().header("Authorization", credentials).build();
22     return chain.proceed(authenticatedRequest);
23   }
24 }
25