Переглянути джерело

add support for multipart uploads

tags/2.0.1
Jonathan Cobb 4 роки тому
джерело
коміт
073dbbc3f8
1 змінених файлів з 12 додано та 2 видалено
  1. +12
    -2
      wizard-common/src/main/java/org/cobbzilla/wizard/client/ApiClientBase.java

+ 12
- 2
wizard-common/src/main/java/org/cobbzilla/wizard/client/ApiClientBase.java Переглянути файл

@@ -508,14 +508,24 @@ public class ApiClientBase implements Cloneable, Closeable {
if (request.getMethod().equals(GET)) {
return HttpUtil.get(getBaseUri() + request.getUri(), new SingletonMap<>(getTokenHeader(), getToken()), headers);
} else if (request.getMethod().equals(POST)) {
return HttpUtil.post(getBaseUri() + request.getUri(), request.getEntityInputStream(), new SingletonMap<>(getTokenHeader(), getToken()), headers);
return HttpUtil.post(getBaseUri() + request.getUri(), request.getEntityInputStream(), null, new SingletonMap<>(getTokenHeader(), getToken()), headers);
} else if (request.getMethod().equals(PUT)) {
return HttpUtil.put(getBaseUri() + request.getUri(), request.getEntityInputStream(), new SingletonMap<>(getTokenHeader(), getToken()), headers);
return HttpUtil.put(getBaseUri() + request.getUri(), request.getEntityInputStream(), null, new SingletonMap<>(getTokenHeader(), getToken()), headers);
} else {
throw new IOException("getStream: unsupported HTTP request method: "+request.getMethod());
}
}

public InputStream uploadMultipartStream(HttpRequestBean request, String name) throws IOException {
if (request.getMethod().equals(POST)) {
return HttpUtil.post(getBaseUri() + request.getUri(), request.getEntityInputStream(), name, new SingletonMap<>(getTokenHeader(), getToken()), headers);
} else if (request.getMethod().equals(PUT)) {
return HttpUtil.put(getBaseUri() + request.getUri(), request.getEntityInputStream(), name, new SingletonMap<>(getTokenHeader(), getToken()), headers);
} else {
throw new IOException("uploadMultipartStream: unsupported HTTP request method: "+request.getMethod());
}
}

public String getStreamedString(HttpRequestBean request) throws IOException {
try {
@Cleanup InputStream in = getStream(request);


Завантаження…
Відмінити
Зберегти