HTTP 302, gdy Google Drive API wysyła powiadomienia push

Question

Po prostu udało mi się zadzwonić do interfejsu Google Drive API, aby włączyć powiadomienia push dla pliku.

Kod skonfigurowaniu powiadomień push wyglądać następująco:

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); 
    } 
} 

Po nazywany doGet serwlety z mojej przeglądarki i zalogowanie się uzyskać to jako odpowiedź:

{ 
    "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" 
} 

Następnym krokiem jest aby zdefiniować kontroler, który otrzymuje powiadomienia, gdy plik jest modyfikowany. Wygląda następująco:

@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"); 
    } 
} 

końcu spróbować zmodyfikować plik po wdrożeniu aplikacji (jest on zainstalowany na Google App Engine) i po patrząc na dzienników w GAE widzę, że doszło do połączenia. Jednak moja metoda odbierania nie jest wykonywana. Widzę tylko 302 w dzienniku z dołączonym dużym jsonem. Naprawdę nie widzę żadnego błędu poza tym, że nie zauważam, że moja metoda jest wywoływana. Ścieżka nawet wygląda poprawnie w dzienniku. Co mogłem robić źle?

Szczegóły dotyczące błędu:

Kiedy idę do strony dziennika w Google Cloud widzę to 302 wiadomość:

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 

Istnieje również json patrząc niby tak:

{ 
    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> 

Zrzut ekranu z dziennika:

Answer 1

Ponieważ zwrotna jest podawane przez wiosennym MVC, upewnij się, że nie ma żadnych ukrytych przekierowań skonfigurowanych gdzie indziej. należy najpierw przetestować zwrotnego przy użyciu zwykłego aplet:

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"); 
    } 
} 

A w 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> 

Jeśli 302 odchodzi problem jest z dyspozytorem MVC wiosny, więc warto tam zajrzeć dla wszystkiego, co może spowodować przekierowanie (np. w twoim widoku).