HTTP 302, когда API Диска Google отправляет push-уведомления

Question

Мне просто удалось вызвать API Диска Google, чтобы включить push-уведомления для файла.

создание уведомлений нажимные код выглядит следующим образом:

public class SampleServlet extends AbstractAppEngineAuthorizationCodeServlet { 
    private final static Logger logger = Logger.getLogger(SampleServlet.class.getName()); 
    private static final long serialVersionUID = 1L; 
    // Constants omitted 

    @Override 
    public void doGet(HttpServletRequest req, HttpServletResponse resp) 
      throws IOException, ServletException { 

     AuthorizationCodeFlow authFlow = initializeFlow(); 
     Credential credential = authFlow.loadCredential(getUserId(req)); 

     StringBuilder resultFromWatch = new StringBuilder(); 
     Drive drive = new Drive.Builder(Utils.HTTP_TRANSPORT, Utils.JSON_FACTORY, credential).setApplicationName("t").build(); 

     try { 
      Optional<Channel> channel = watchFile(drive, FILE_ID, CHANNEL_ID, "web_hook", "https://mydomain.appspot.com/drive"); 
      String channelStringTmp; 
      if (channel.isPresent()) { 
       channelStringTmp = channel.get().toString(); 
      } else { 
       channelStringTmp = "null..."; 
      } 
      resultFromWatch.append(channelStringTmp); 
     } catch (Exception e) { 
      resultFromWatch.append(e.getMessage()); 
     } 

     final UserService userService = UserServiceFactory.getUserService(); 
     final String thisUrl = req.getRequestURI(); 
     // Send the results as the response 
     PrintWriter respWriter = resp.getWriter(); 
     resp.setStatus(200); 
     resp.setContentType("text/html"); 

     addLoginLogoutButtons(req, resp, resultFromWatch, userService, thisUrl, respWriter); 
    } 

    private static Optional<Channel> watchFile(Drive service, String fileId, 
               String channelId, String channelType, String channelAddress) throws IOException { 
     final Channel returnValue; 
     Channel channel = new Channel(); 
     channel.setId(channelId); 
     channel.setType(channelType); 
     channel.setAddress(channelAddress); 
     Drive.Files tmp = service.files(); 
     returnValue = tmp.watch(fileId, channel).execute(); 
     return Optional.fromNullable(returnValue); 
    } 

    @Override 
    protected AuthorizationCodeFlow initializeFlow() throws ServletException, IOException { 
     return Utils.initializeFlow(); 
    } 

    @Override 
    protected String getRedirectUri(HttpServletRequest req) throws ServletException, IOException { 
     return Utils.getRedirectUri(req); 
    } 
} 

После называется сервлеты doGet из моего браузера и входа в систему я получаю это как ответ:

{ 
    "expiration": "1484565747000", 
    "id": SAME_ID_AS_DEFINED_IN_SERVLET, 
    "kind": "api#channel", 
    "resourceId": A_NEW_ID, 
    "resourceUri": "https:\/\/www.googleapis.com\/drive\/v3\/files\/FILE_ID?acknowledgeAbuse=false&alt=json" 
} 

Следующий шаг для определения моего контроллера, который получает уведомления при изменении файла. Похоже, это:

@RestController 
@RequestMapping("/drive") 
public class ConcreteFileWatchController implements FileWatchController { 
    private final static Logger logger = Logger.getLogger(ConcreteFileWatchController.class.getName()); 

    @RequestMapping(method = RequestMethod.POST) 
    @ResponseStatus(value = HttpStatus.OK) 
    @Override 
    public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException { 
     logger.info("Received watch call"); 
    } 
} 

Наконец я пытаюсь изменить файл после развертывания приложения (он развернут на Google App Engine) и после просмотра журналов в GAE я вижу, что там был вызов. Однако мой метод приема не выполняется. Я вижу только 302 в журнале с большим json, прикрепленным к нему. Невозможно увидеть какую-либо ошибку, за исключением того, что я не замечаю, что вызван мой метод. Путь даже выглядит корректно в журнале. Что я могу делать неправильно?

Подробная информация об ошибке:

Когда я иду на страницу Войти Google Cloud Я вижу это 302 сообщение:

11:34:35.957 
POST 
302 
0 B 
22 ms 
APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html) 
/drive 
10.72.94.97 - - [16/Jan/2017:11:34:35 +0100] "POST /drive HTTP/1.1" 302 - - "APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html)" "mydomain.appspot.com" ms=22 cpu_ms=0 cpm_usd=0 loading_request=0 instance=- app_engine_release=1.9.48 trace_id=d0e888dd3989e353344e40e41758fdf4 

Существует также JSON ищет вроде этого:

{ 
    protoPayload: { 
    @ 
    type: "type.googleapis.com/google.appengine.logging.v1.RequestLog" 
    appId: "p~blabla" 
    versionId: "201t113050" 
    requestId: "587ca1bb00ff05706f727465726261636b656e640001323031373031313674313133303530000100" 
    ip: "10.76.94.97" 
    startTime: "2017-01-16T10:34:35.957904Z" 
    endTime: "2017-01-16T10:34:35.980366Z" 
    latency: "0.022462s" 
    method: "POST" 
    resource: "/drive" 
    httpVersion: "HTTP/1.1" 
    status: 302 
    userAgent: "APIs-Google; (+https://developers.google.com/webmasters/APIs-Google.html)" 
    host: "blabla.appspot.com" 
    instanceIndex: -1 
    finished: true 
    appEngineRelease: "1.9.48" 
    traceId: "d0e888dd390f41758fdf4" 
    first: true 
} 
insertId: "587cf6df9ded23f7" 
httpRequest: { 
status: 302 
} 
resource: { 
type: "gae_app" 
labels: {…} 
} 
timestamp: "2017-01-16T10:34:35.957904Z" 
labels: { 
appengine.googleapis.com/version_id: "2017013050" 
clone_id: "" 
appengine.googleapis.com/clone_id: "" 
appengine.googleapis.com/module_id: "default" 
version_id: "20170116t113050" 
request_id: "587ca1bb00ff0e9dd0f39f31350001707e6561737974696d657265706f721373031313674313133303530000100" 
appengine.googleapis.com/request_id: "587ca1bb00ff0e9dd0f39f31350001707e6561737974696d6572653674313133303530000100" 
module_id: "default" 
} 
logName: "projects/blabla/logs/appengine.googleapis.com%2Frequest_log" 
operation: { 
id: "587ca1bb00ff0e9dde640001323031373031313674313133303530000100" 
producer: "appengine.googleapis.com/request_id" 
first: true 
last: true 
} 
} 

web.xml:

<web-app> 
    <context-param> 
     <param-name>contextConfigLocation</param-name> 
     <param-value>/WEB-INF/mvc-dispatcher-servlet.xml</param-value> 
    </context-param> 
    <filter> 
     <filter-name>CORS</filter-name> 
     <filter-class>com.thetransactioncompany.cors.CORSFilter</filter-class> 
    </filter> 
    <filter-mapping> 
     <filter-name>CORS</filter-name> 
     <url-pattern>/*</url-pattern> 
    </filter-mapping> 
    <listener> 
     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 
    </listener> 
    <servlet> 
     <servlet-name>dispatcher</servlet-name> 
     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> 
     <init-param> 
      <param-name>contextConfigLocation</param-name> 
      <param-value></param-value> 
     </init-param> 
     <load-on-startup>1</load-on-startup> 
    </servlet> 

    <servlet> 
     <servlet-name>PlusBasicServlet</servlet-name> 
     <servlet-class>packagename.PlusBasicServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusBasicServlet</servlet-name> 
     <url-pattern>/plusbasicservlet</url-pattern> 
    </servlet-mapping> 

    <servlet> 
     <servlet-name>PlusSampleServlet</servlet-name> 
     <servlet-class>packagename.PlusSampleServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusSampleServlet</servlet-name> 
     <url-pattern>/plussampleservlet</url-pattern> 
    </servlet-mapping> 
    <servlet> 
     <servlet-name>FileWatchTestServlet</servlet-name> 
     <servlet-class>packagename.ConcreteFileWatchController</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>FileWatchTestServlet</servlet-name> 
     <url-pattern>/drive</url-pattern> 
    </servlet-mapping> 
    <servlet> 
     <servlet-name>PlusSampleAuthCallbackServlet</servlet-name> 
     <servlet-class>packagename.PlusSampleAuthCallbackServlet</servlet-class> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>PlusSampleAuthCallbackServlet</servlet-name> 
     <url-pattern>/oauth2callback</url-pattern> 
    </servlet-mapping> 
    <security-constraint> 
     <web-resource-collection> 
      <web-resource-name>any</web-resource-name> 
      <url-pattern>/plussampleservlet</url-pattern> 
     </web-resource-collection> 
     <auth-constraint> 
      <role-name>*</role-name> 
     </auth-constraint> 
    </security-constraint> 
</web-app> 

Скриншот из журнала:

Answer 1

Поскольку ваш обратный вызов обслуживается через Spring MVC, убедитесь, что у вас нет каких-либо скрытых редиректов настроенных в других местах. Вы должны сначала проверить функцию обратного вызова с помощью обычного сервлета:

public class FileWatchTestServlet extends HttpServlet { 
    private final static Logger logger = Logger.getLogger(FileWatchTestServlet.class.getSimpleName()); 

    @Override 
    public void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException { 
     logger.info("Received watch call"); 
    } 
} 

И в web.xml:

<servlet> 
    <servlet-name>FileWatchTestServlet</servlet-name> 
    <servlet-class>com.mydomain.FileWatchTestServlet</servlet-class> 
</servlet> 
<servlet-mapping> 
    <servlet-name>FileWatchTestServlet</servlet-name> 
    <url-pattern>/drive</url-pattern> 
</servlet-mapping> 

Если 302 уходит, проблема связана с диспетчером Spring MVC, так что вы должны смотреть там для всего, что может вызвать перенаправление (например, на ваш взгляд).