Merge pull request #257 from line/next

Release 7.1.0

Author: xingoxu

CHANGELOG.md

@@ -1,3 +1,21 @@
+## 7.1.0 (18 Sep 2020)
+
+### Feature
+* Messaging API - August 2020 update (#240)(#251)(#258)
+* Messaging API - September 2020 update (#248)
+* Add Video viewing complete event (#241)
+* Channel access token v2.1 support key id (#231)
+* OAuth API v2.1 endpoint change (#233)
+
+### Bug fix
+* Accept label in richmenu area actions (#246)
+* Update dependencies & fix format (#234)(#236)(#238)(#243)(#250)
+* fix: fix createUploadAudienceGroup & updateUploadAudienceGroup API doc (#249)
+
+### Misc
+* Add Release CI & change release flow (#256)
+* Add: build doc github workflow
+
 ## 7.0.0 (15 June 2020)
 
 ### Breaking Changes

docs/api-reference/client.md

@@ -83,8 +83,8 @@ class Client {
   // AudienceGroup
   createUploadAudienceGroup(uploadAudienceGroup: {
     description: string;
-    isIfaAudience: boolean;
-    audiences: { id: string }[];
+    isIfaAudience?: boolean;
+    audiences?: { id: string }[];
     uploadDescription?: string;
   }) : Promise<{
       audienceGroupId: number;
@@ -93,15 +93,36 @@ class Client {
       created: number;
       requestId: string;
     }>
+  createUploadAudienceGroupByFile(uploadAudienceGroup: {
+    description: string;
+    isIfaAudience?: boolean;
+    uploadDescription?: string;
+    file: Buffer | Readable;
+  }) : Promise<{
+      audienceGroupId: number;
+      type: "UPLOAD";
+      description: string;
+      created: number;
+    }>
   updateUploadAudienceGroup(
     uploadAudienceGroup: {
       audienceGroupId: number;
       description?: string;
       uploadDescription?: string;
       audiences: { id: string }[];
     },
+    // for set request timeout
     httpConfig?: Partial<AxiosRequestConfig>,
-  ): Promise<{}>
+  ) : Promise<{}>
+  createUploadAudienceGroupByFile(
+    uploadAudienceGroup: {
+      audienceGroupId: number;
+      uploadDescription?: string;
+      file: Buffer | Readable;
+    },
+    // for set request timeout
+    httpConfig?: Partial<AxiosRequestConfig>,
+  }) : Promise<{}>
   createClickAudienceGroup(clickAudienceGroup: {
     description: string;
     requestId: string;

lib/client.ts

@@ -2,8 +2,7 @@ import { Readable } from "stream";
 import HTTPClient from "./http";
 import * as Types from "./types";
 import { AxiosResponse, AxiosRequestConfig } from "axios";
-
-import { ensureJSON, toArray } from "./utils";
+import { createMultipartFormData, ensureJSON, toArray } from "./utils";
 
 type ChatType = "group" | "room";
 type RequestOption = {
@@ -455,8 +454,8 @@ export default class Client {
 
   public async createUploadAudienceGroup(uploadAudienceGroup: {
     description: string;
-    isIfaAudience: boolean;
-    audiences: { id: string }[];
+    isIfaAudience?: boolean;
+    audiences?: { id: string }[];
     uploadDescription?: string;
   }) {
     const res = await this.http.post<{
@@ -470,6 +469,25 @@ export default class Client {
     return ensureJSON(res);
   }
 
+  public async createUploadAudienceGroupByFile(uploadAudienceGroup: {
+    description: string;
+    isIfaAudience?: boolean;
+    uploadDescription?: string;
+    file: Buffer | Readable;
+  }) {
+    const file = await this.http.toBuffer(uploadAudienceGroup.file);
+    const body = createMultipartFormData({ ...uploadAudienceGroup, file });
+    const res = await this.http.post<{
+      audienceGroupId: number;
+      type: "UPLOAD";
+      description: string;
+      created: number;
+    }>(`${DATA_API_PREFIX}/audienceGroup/upload/byFile`, body, {
+      headers: body.getHeaders(),
+    });
+    return ensureJSON(res);
+  }
+
   public async updateUploadAudienceGroup(
     uploadAudienceGroup: {
       audienceGroupId: number;
@@ -490,6 +508,26 @@ export default class Client {
     return ensureJSON(res);
   }
 
+  public async updateUploadAudienceGroupByFile(
+    uploadAudienceGroup: {
+      audienceGroupId: number;
+      uploadDescription?: string;
+      file: Buffer | Readable;
+    },
+    // for set request timeout
+    httpConfig?: Partial<AxiosRequestConfig>,
+  ) {
+    const file = await this.http.toBuffer(uploadAudienceGroup.file);
+    const body = createMultipartFormData({ ...uploadAudienceGroup, file });
+
+    const res = await this.http.put<{}>(
+      `${DATA_API_PREFIX}/audienceGroup/upload/byFile`,
+      body,
+      { headers: body.getHeaders(), ...httpConfig },
+    );
+    return ensureJSON(res);
+  }
+
   public async createClickAudienceGroup(clickAudienceGroup: {
     description: string;
     requestId: string;

lib/http.ts

@@ -96,29 +96,31 @@ export default class HTTPClient {
     return res.data;
   }
 
+  public async toBuffer(data: Buffer | Readable) {
+    if (Buffer.isBuffer(data)) {
+      return data;
+    } else if (data instanceof Readable) {
+      return await new Promise<Buffer>((resolve, reject) => {
+        const buffers: Buffer[] = [];
+        let size = 0;
+        data.on("data", (chunk: Buffer) => {
+          buffers.push(chunk);
+          size += chunk.length;
+        });
+        data.on("end", () => resolve(Buffer.concat(buffers, size)));
+        data.on("error", reject);
+      });
+    } else {
+      throw new Error("invalid data type for binary data");
+    }
+  }
+
   public async postBinary<T>(
     url: string,
     data: Buffer | Readable,
     contentType?: string,
   ): Promise<T> {
-    const buffer = await (async (): Promise<Buffer> => {
-      if (Buffer.isBuffer(data)) {
-        return data;
-      } else if (data instanceof Readable) {
-        return new Promise<Buffer>((resolve, reject) => {
-          const buffers: Buffer[] = [];
-          let size = 0;
-          data.on("data", (chunk: Buffer) => {
-            buffers.push(chunk);
-            size += chunk.length;
-          });
-          data.on("end", () => resolve(Buffer.concat(buffers, size)));
-          data.on("error", reject);
-        });
-      } else {
-        throw new Error("invalid data type for postBinary");
-      }
-    })();
+    const buffer = await this.toBuffer(data);
 
     const res = await this.instance.post(url, buffer, {
       headers: {

lib/utils.ts

@@ -1,4 +1,5 @@
 import { JSONParseError } from "./exceptions";
+import * as FormData from "form-data";
 
 export function toArray<T>(maybeArr: T | T[]): T[] {
   return Array.isArray(maybeArr) ? maybeArr : [maybeArr];
@@ -11,3 +12,18 @@ export function ensureJSON<T>(raw: T): T {
     throw new JSONParseError("Failed to parse response body as JSON", raw);
   }
 }
+
+export function createMultipartFormData(
+  this: FormData | void,
+  formBody: Record<string, any>,
+): FormData {
+  const formData = this instanceof FormData ? this : new FormData();
+  Object.entries(formBody).forEach(([key, value]) => {
+    if (Buffer.isBuffer(value) || value instanceof Uint8Array) {
+      formData.append(key, value);
+    } else {
+      formData.append(key, String(value));
+    }
+  });
+  return formData;
+}

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@line/bot-sdk",
-  "version": "7.0.0",
+  "version": "7.1.0",
   "description": "Node.js SDK for LINE Messaging API",
   "engines": {
     "node": ">=10"
@@ -40,7 +40,8 @@
     "@types/node": "^14.10.0",
     "axios": "^0.20.0",
     "body-parser": "^1.19.0",
-    "file-type": "^15.0.0"
+    "file-type": "^15.0.0",
+    "form-data": "^3.0.0"
   },
   "devDependencies": {
     "@types/express": "^4.17.8",

package.json

@@ -9,4 +9,4 @@ npm run generate-changelog
 
 git add -A
 git commit -m "(Changelog CI) Added Changelog"
-git push -u origin ${GITHUB_HEAD_REF} --tags
+git push -u origin ${GITHUB_HEAD_REF}