20210117のNode.jsに関する記事は13件です。

投稿日：2021-01-17T21:15:41+09:00

【Node.js Sequalize】 Unable to find migration: エラーの解決法

マイグレーションの誤操作により、マイグレートをかけた時に、削除したマイグレーションファイルが引っかかってきて、下記の様なエラーが表示された場合の解決法。
ERROR: Unable to find migration: 20210105140820-create-user.js
一旦,migrationsディレクトリの中に表示されたファイルを作成する。
20210105140820-create-user.js
'use strict';

module.exports = {
  up: function (queryInterface, Sequelize) {
    return Promise.resolve()
  },

  down: function (queryInterface) {
    return Promise.resolve()
  }
};
全てのマイグレーションをロールバックする。
npx sequelize-cli db:migrate:undo:all
先ほど作成したファイルを削除する。

マイグレートをかける。
npx sequelize-cli db:migrate --env development
以上

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T18:47:20+09:00

[Node.js] 2021年版サービスアカウント認証コード with ドメイン全体の委任

はじめに

2020年10月に G Suite が Google Workspace にリブランドされました。
それとは全く関係ないですが Google Classroom や Google Chat などの Google Apis を Node.js 用クライアントである googleapis を使って呼び出す際に、サービスアカウントに対してドメイン全体の委任を行い OAuth 認証を行う必要があったのですが、情報を見つけるのに大分彷徨ってしまったり、見つけたコードの記法が少々古かったり、ポイントとなる subject の指定方法がやや不適切だったりしたので備忘を兼ねてコードを残しておきます。

認証コード

一応 googleapis のバージョンは 67.0.0 です。古いバージョン（39.2.0とか）でも動きます。
const { google } = require('googleapis');
const credentials = require('./credentials.json'); // サービスアカウント秘密鍵jsonファイル
// ドメイン全体の委任で承認されている OAuth スコープの中から必要な分だけ指定する
const scopes = [
  'https://www.googleapis.com/auth/classroom.courses.readonly'
];
// API 呼出し主体となるアカウントを指定。無指定だとパーミッションエラーになる
const clientOptions = { subject: 'great-teacher@my-domain.com' };

async function main() {
  const auth = await google.auth.getClient({ credentials, scopes, clientOptions });
  const classroom = google.classroom({ version: 'v1', auth });

  // api 単位ではなくグローバルオプションとして認証情報をセットする場合は下記のようにする
  // const classroom = google.classroom({ version: 'v1' });
  // google.options({ auth });

  const response = await classroom.courses.list();
  console.log(JSON.stringify(response));
}

main().catch(err => {
  console.error(err);
  process.exit(1);
});
ポイント

getClient のパラメーターとして subject を指定した clientOptions を渡す点が重要です。
これを指定しないと 403 エラー (The caller does not have permission) が返ってきます。
逆に指定した場合はそのアカウントで認証して API を呼び出した場合と同じ結果が返ってきます。
例えば Classroom において教師A が課題1～10、教師B が課題11～20 を作成していた場合、
subject に教師A のアカウントを指定して courses.courseWork.list() を実行すれば課題1～10が、
教師B のアカウントを指定して実行すれば課題11～20 が返ってきます。

また、ここでは require を使って秘密鍵 Json ファイルをオブジェクトとして読み込んで credentials パラメーターに渡していますが、下記のようにファイルパスを keyFile パラメーターに渡しても良いです。
  const auth = await google.auth.getClient({ keyFile: './credentials.json', scopes, clientOptions });
付録：サービスアカウント作成とドメイン全体の委任

一応この記事だけ見れば良いようにサービスアカウント作成と、そのアカウントに対するドメイン全体の委任の手順を記載しておきます。ドメイン全体の委任についてはGoogle Workspaceの管理者しか実施できず、説明するためのスクショを撮るのもままならなかったりしますので。

OAuth 同意画面の設定

API とサービス > OAuth 同意画面
ここで設定したアプリ名が Google 管理コンソールでドメイン全体の委任を設定した際に表示されます。

OAuth 同意画面の設定手順

OAuth 同意画面

下記のとおり設定し「作成」または「保存して次へ」

UserType：目的に応じて選択

アプリ情報

アプリ名：適切な名前を入力

ユーザーサポートメール：プルダウンから選択

アプリのロゴ：空でOK。ある場合は指定

アプリのドメイン：全て空でOK。ある場合は指定

承認済みドメイン：追加なしでOK

デベロッパーの連絡先情報

メールアドレス：適切に指定



スコープ

なにも設定せず「保存して次へ」

テストユーザー

なにも設定せず「保存して次へ」

サービスアカウントの準備

API とサービス > 認証情報

サービスアカウントの準備手順

サービスアカウント作成

+ 認証情報の作成 から サービスアカウント を選択。

下記のとおり設定して「完了」

サービスアカウント名：適当に（ここでは domain-delegation）

サービスアカウントID：自動設定

サービスアカウントの説明：空ないし任意の説明文

ドメイン全体の委任を有効化

作成したサービスアカウントの編集ボタンをクリック。

ドメイン全体の委任の表示 をクリックして展開。
G Suite ドメイン全体の委任を有効にする にチェックを入れて「保存」

これにより「OAuth 2.0 クライアント ID」が表示されたことを確認し、再度サービスアカウントの編集ボタンをクリック。

鍵を追加 プルダウンから 新しい鍵を作成 をクリック。
キーのタイプとして「JSON」を選択して「作成」し、秘密鍵Jsonファイルをダウンロード。
このファイルがソースコード上で require('./credentials.json') により取り込んでいた json ファイル。

このサービスアカウント用の OAuth クライアント ID は一覧のコピーボタンから取得する。

ドメイン全体の委任の承認

Google 管理コンソール > セキュリティ

ドメイン全体の委任の承認手順

セキュリティ項目一番下の API の制御 パネルをクリック。

API の制御項目の一番下の ドメイン全体の委任 にある「ドメイン全体の委任を管理」をクリック。

API クライアント一覧にある「新しく追加」をクリック。

クライアント ID にサービスアカウントの OAuth クライアント ID、スコープに利用する Google APIs に必要なスコープを必要な数だけ入力して「承認」。
（カンマ区切りと書いてあるが、1 つ入力するたびにテキストボックスが増えていくので 1 つずつ入力すればよい）

おわりに

探し方が悪いのかサービスアカウント認証関連の公式ドキュメントを探しても subject を指定しなきゃダメという情報を見つけられず、参考にさせて頂いた記事を見てようやく認証を通すことができました。
一応 subject の指定方法は適切な形になっているはずですし、async/await 版でのサンプルにもなっていると思いますので参考になれば。

参考

GoogleAPI SDK ServiceAccount認証コード（Ruby or Node.js）

Node.jsでGCPサービスアカウント使用したG Suiteアカウント情報取得の実装

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T18:05:27+09:00

Amazon Transcribeをストリーミングで実行する

はじめに

Amazon Transcribe は音声データをテキスト化する（文字起こしとも言われる）サービスです

音声ファイルを準備してバッチ処理するタイプと、音声をストリーミングして、リアルタイム（逐次的に）処理するタイプがあります

日本語については、2020年11月にリアルタイム処理タイプに対応しました

AWSコンソール上ではブラウザの音声をTranscribeへストリーミングすることで機能を確認することができます。レスポンス良くテキスト化されます

実際の業務等ではマネジメントコンソールで使うことはなく、アプリケーション等に組み込むことになると思います

ということで、サンプル的にストリーミング処理を実装してみました

そして自分への備忘も兼ねて処理内容の解釈を記述します

なお、SDK v3はpreviewなので、これからリリースされる正式バージョンと異なる（動作しない）可能性があります

環境

Ubuntu 20.04 on WSL2

Node.js v14.15.4

AWS SDK for JavaScript version 3(preview)

サンプルコード

下記コードをタタキ台として説明します

https://github.com/shinsaka/transcribe-stream-sample

実行手順

オーディオファイルを準備する

バッチ処理ではなくリアルタイムストリーム処理、と言ったわりには音声ファイルを準備します

音声入力部分も何らかのストリームにする想定ですが、今回はTranscribeとのストリーム部分にフォーカスし、シンプルにしました

（手元ではKinesisVideoStreamからの音声をTranscribeへパイプできることまで確認しています）

オーディオファイルの仕様

符号付き16ビット PCM 8KHz RAW（ヘッダ無）

指定がある場合はリトルエンディアンを選択

Audacity を利用して変換するのが簡単です

実行環境の準備

Node.jsの環境作成

各自準備してください

githubからソースファイルを手元へコピー

git clone などで

パッケージインストール

npm install

実行

ニュース動画の音声で試してみました

下記のようになります

音声が30秒ぐらいで、処理時間も30秒+αかかります

アナウンサーの発声ということもあってか、正確にテキスト化されています

来月なのか? 部分が正確には 来月七日 ですが、他は誤変換もなく素晴らしい精度です
$ node transcription.js sample_audio.raw
0.08: きょう 東京 都心 は ぽかぽか 陽気 と なり 最高 気温 は 昨日 より 十 一 度、 以上 高い 十 八、 七 度 と か
8.39: 四 月 中旬 並み の 暖か さ と なり まし た
11.98: 江戸川 区 の 葛西 臨海 公園 に は 多く の 家族 連れ の 姿 が。
17.54: 東京 都 で は 緊急 事態 宣言 の 解除 が 予定 さ れ て いる 来月 な の か? まで
23.15: 上野 動物 園 や 葛西 臨海 水 族 園 など 都立 の 動物 園 や 水 族 館 を 臨時 休業 に し て い ます
コードの解説

対象ソースファイル

https://github.com/shinsaka/transcribe-stream-sample/blob/main/transcription.js

const parseTranscribeStream... 部分

Transcribeからのレスポンス解釈部です

Transcribeからのレスポンスオブジェクトを表示用に編集しています

IsPartial == true の場合は変換途中を示していますので表示から省いています

条件を外して実行してみると挙動がわかると思います

const audioSource = createReadStream 部分

音声ファイルを読み込みしています

highWaterMarkで一度に読み込むサイズを1KBに抑えています

大きいサイズを送信するとTranscribe側がエラーを返すことがあります

const audioStream = async function* 部分

音声ファイルのデータ片を所定のオブジェクト形式に変換しています

const command = new StartStreamTranscriptionCommand 部分

Transcribeとのリアルタイムストリーム開始コマンドを作成しています

日本語、PCM形式、8KHzであることを伝えています

入力は前段で定義したストリームを指定しています

処理が開始すると、入力ストリームから順次データを受け取り、処理する記述です

const client = new TranscribeStreamingClient 部分

Transcribeとのリアルタイムストリーム開始リクエストクライアントを作成しています

パラメータ requestHandler でセッションタイムアウトを5秒指定しています

これを指定しないと音声データ送信が終了しても5分ぐらい通信が切断されません

SDK内部でコネクションプールしていますが、データ終了時にクローズせず、プールしたままになっているようです

SDKはまだpreviewなので改善するかもしれません

const response = await client.send(command) 部分

Transcribeとのリアルタイムストリーム開始リクエストしています

SDK v3では基本的に「コマンド作成」して、client.send()する記述になるようですね

const transcriptsStream = Readable.from(response.TranscriptResultStream) 部分

Transcribeからのレスポンスを受け取るストリームを宣言しています

transcriptsStream.pipe(parseTranscribeStream).pipe(stdout) 部分

ストリームをパイプで接続しています

Transcribeからのレスポンスを冒頭で記述したレスポンス解釈部へ

レスポンス解釈部のアウトプットを標準出力へ

まとめ

Node.jsの非同期ストリーム処理によってシンプルに実装できる印象です

そのぶん、どこで何が処理されているか理解しておかないとハマるかもしれません

この実装だと、HTTP/2 Streaming 動作になると思います

実は SDK v2で WebSockets Streaming も試していたのですが、途中でv3に気づいて移ってきました

あまり詳しくないのですが、HTTP/2ストリーミングだと送信ごとに毎回署名してるようなので効率は落ちるのでしょうかね

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T17:07:57+09:00

Node.js × Expressで始めるGraphQL入門

概要

GraphQLを初めて実装してみた時の手順と、サンプルソースコードを記載しています。

環境

macOS Big Sur 11.1

node v14.12.0

yarn 1.22.10

express 4.16.1

Docker version 19.03.13

docker-compose version 1.27.4

サンプルソースコード

hayatoiwashita/express-graphql

手順

1. プロジェクトの雛形を作成

express-generatorを使用した。
--gitオプションは.gitignoreを追加するためのオプション。
$ express --view=pug --git express-graphql
参考: Express のアプリケーション生成プログラム

2. ライブラリのインストール

GraphQL関連のライブラリは最低限下記があればOK。
$ yarn add graphql
$ yarn add express-graphql
サンプルでは下記も追加している(本題から逸れるので割愛)
# ホットリロード
$ yarn add --dev nodemon
# コード整形
$ yarn add prettier --dev --exact
$ yarn add eslint --dev
$ yarn add --dev eslint-config-prettier
$ yarn add --dev eslint-plugin-prettier
# commit時にコード整形を実行
$ yarn add --dev lint-staged
$ yarn add --dev husky
3. サンプルデータの用意

/data/users.jsを追加して、DBの代わりに使用した。
(内容はサンプルソースコードのusers.jsを参照)

4. schemaを定義

/schema/schema.graphqlを作成してschemaを定義。
今回は参照系クエリのみ実装した。
データ構造は、ユーザとそれに紐づく投稿といった形。
schema.graphql
const { buildSchema } = require("graphql");

const schema = buildSchema(`
    type Query {
        users: [User!]!,
        user(id: Int!): User!
    }

    type User {
        id: ID!
        name: String!
        email: String
        posts: [Post!]
    }

    type Post {
        id: ID!
        title: String!
        published: Boolean!
        link: String
        author: User!
    }
`);

module.exports = schema;
5. リゾルバを作成

データ操作を行う/src/resolvers.jsを作成。
上述の通り、今回は参照系のみ。
resolvers.js
const { Users } = require('../data/users');

const resolvers = {
  users: async (_) => {
    console.log('come here');
    return Users;
  },
  user: async ({ id }, context) => {
    return Users.find((user) => user.id == id);
  },
};

module.exports = resolvers;
6. app.js を修正

エンドポイント/graphqlを定義。
app.js
// var createError = require('http-errors');
var express = require('express');
var { graphqlHTTP } = require('express-graphql');
var resolvers = require('./src/resolvers');
var schema = require('./schema/schema.graphql');
var path = require('path');
var cookieParser = require('cookie-parser');
var logger = require('morgan');

var app = express();

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'pug');

app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use(
  '/graphql',
  graphqlHTTP({
    schema,
    rootValue: resolvers,
    graphiql: true,
  })
);

module.exports = app;
7. [参考] コンテナ化

Dockerfileとdocker-compose.ymlを追加。
FROM node:14.15.4-slim

WORKDIR /usr/local/src/express-graphql
ADD . .
RUN yarn install
CMD [ "yarn", "start" ]
docker-compose.yml
version: '3'

services:
  graphql:
    build: .
    container_name: graphql-container
    ports:
      - "3000:3000"
8. Expressの起動

起動コマンドを実行。
# コンテナで実行
$ docker-compose up

# コンテナを使用せず実行
$ yarn start
9. クエリを実行

http://localhost:3000/graphql をブラウザで開く。

【サンプルクエリ】
内容としては、ユーザID=1のユーザの名前と、そのユーザの投稿(posts)のIDとタイトルを取得するというもの。
{
  user(id:1) {
    name
    posts {
      id
      title
    }
  }
}
実行結果
{
  "data": {
    "user": {
      "name": "Fikayo Adepoju",
      "posts": [
        {
          "id": "1",
          "title": "Debugging an Ionic Android App Using Chrome Dev Tools"
        },
        {
          "id": "2",
          "title": "Hosting a Laravel Application on Azure Web App"
        }
      ]
    }
  }
}
参考

GraphQLをNode.jsとexpressでためしてみる

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T16:07:45+09:00

Azure IoT Hub に Node.js で publish

Ubuntu 20.10 で確認しました。

ライブラリーのインストール

sudo npm install -g azure-iot-device-mqtt
sudo npm install -g azure-iot-device

azure_publish.js

#! /usr/bin/node
// ---------------------------------------------------------------
//  azure_publish.js
//
//                  Jan/20/2021
//
// ---------------------------------------------------------------
'use strict'
var devicemqtt = require('azure-iot-device-mqtt')
var device = require('azure-iot-device')
const dotenv = require('dotenv')
//
// ---------------------------------------------------------------
function printResultFor(op) {
    return function printResult(err, res) {
    if (err) console.log(op + ' error: ' + err.toString())
    if (res) console.log(op + ' status: ' + res.constructor.name)
    }
}
// ---------------------------------------------------------------
function define_data_proc ()
{
    const device_id = "atami"
    const jikan= new Date()
    const hour = jikan.getHours()
    const minute = jikan.getMinutes()
    const second = jikan.getSeconds()
    const current_time = "" + hour + ":" + minute + ":" + second
        const tt = (20 + (Math.random() * 15)) * 10
        const temperature = Math.round (tt) / 10
        const hh = (60 + (Math.random() * 20)) * 10
        const humidity = Math.round (hh) / 10
        const ddx = { device_id: device_id, time: current_time, temperature: temperature, humidity: humidity }
        const data = JSON.stringify(ddx)

    return data
}

// ---------------------------------------------------------------
console.error ("*** 開始 ***")
dotenv.config()
const connectionString = `${process.env.CONNECTSTRING}`
console.log(connectionString)

var Message = device.Message

var client = devicemqtt.clientFromConnectionString(connectionString)

var connectCallback = function (err) {
if (err)
    {
    console.error('Could not connect: ' + err);
    }
else
    {
    console.log('Client connected')

    const data =  define_data_proc ()
    var message = new Message(data)
    console.log("Sending message: " + message.getData())
    client.sendEvent(message, printResultFor('send'))
console.error ("*** ppp ***")
    }
console.error ("*** qqq ***")
}

client.open(connectCallback)
console.error ("*** rrr ***")

console.error ("*** 終了 ***")
// ---------------------------------------------------------------

.env

CONNECTSTRING="HostName=iot-aa.azure-devices.net;DeviceId=pansy;SharedAccessKey=SvsFWVsCy2bJkH0QuPJeIabcdefgh8mo6S6vNCjom92="

プライマリ接続文字列をポータルで調べる必要があります。

次のコマンドでも調べることが出来ます。

az iot hub device-identity connection-string show --hub-name iot-aa \
    --device-id pansy --output table

実行コマンド

export NODE_PATH=/usr/lib/node_modules
./azure_publish.js

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T15:57:20+09:00

【Promiseとは】

【Promiseとは】

Promiseはrejectedかfulfilledという結果が帰ってくることを約束してくれる。

そのため、それらに対するハンドリングがしやすいといったメリットがあると勉強していて感じた。実際、Node.jsの各メソッドをPromiseインスタンスに変換できるようなものが導入されたりとそのうちPromiseの規格に統一されるかもしれない。

【Promiseの挙動】

Promiseは、Promiseインスタンスを返す。

その時、Promiseインスタンスは最終的に、rejectedかfulfilledを返すが、それは以下のようにpendingな状態をreject()かresolve()で解決しないといけない。
         pending
　　　　　　　↓
　　　　　　／ ＼
    reject()   resolve()
       ↓         ↓
　 rejected     fulfilled    <=  これらの状態をsettledという
【Promiseインスタンスをsettled状態にしてみる】

まずPromiseはnew Promise() のようにして一度pendingな状態にする方法と、

pending状態を経ずに直接fulfilled、rejected状態にする2パターンある。
// 一度pendingにする
// settledにするには一度変数に入れて、setTimeoutで3000経過させるなどしないといけない
function asyncFunc(){
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            try{ 
                resolve('成功')
            }catch(err){
                reject(err)
        }},3000)
    })
}
console.log(asyncFunc()) => Promise { <pending> }

// 直接resolve、rejected
Promise.resolve('成功') => Promise { '成功' }
Promise.reject(new Error('エラー')) => Promise { <rejected> Error: エラー ~~(省略)
【settled状態を利用して次の処理をおこなう】

.then()、.catch()、を使えば、Promiseインスタンスがsettledになったら、実行するコールバック処理を設置できる。

以下の処理は、Promiseが1でfulfilled状態になり、その結果を.then()のnumで受け取っている。

Promiseでコールバックヘルが解決できるのはこういったことができるからだ。
Promise.resolve(1)
             .then(num => console.log('resolve', num))
上記の.then()は省略されており、第二引数には.then()で起きたエラーの処理を受け取れるようになっている。しかし、これは.then()が多くなると長くなる。

.catch()を最後につけることで.then()で起きたエラーを全て一箇所で受け取れる。
// 同じことをしている
Promise.resolve(1)
             .then(
                    num => console.log('resolve', num),
                    err => new Error('エラー')
             )

Promise.resolve(1)
             .then(num => console.log('resolve', num))
             .catch(err => new Error('エラー'))
【複数のPromiseを並行に処理してみる】

・ Promise.all　

中のPromiseインスタンスが全部fulfilledになったら、その値でfulfilledを返す。

これだと各処理が平行に実行されるので効率がいい。
const all = Promise.all(
    [1,Promise.resolve('成功'), Promise.resolve('fulfilled')]
)
all => Promise { [ 1, '成功', 'fulfilled' ] }
・Promise.allSettled

中のPromiseインスタンスがfulfilledかrejectedかに関わらずそれぞれの結果を返す。

とりあえず結果をきにせず平行に処理したい時に便利かも。
const allSettled = Promise.allSettled([
    Promise.resolve('成功'), Promise.reject(new Error('エラー'))
])
allSettled => Promise {[
    { status: 'fulfilled', value: '成功' },
    { status: 'rejected',
      reason: Error: エラー ~ (省略)
Node.jsでよく使うasync awaitもPromiseインスタンスをawaitの直前に置くことで実装できるように設計されているためPromiseの理解が重要。

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T15:57:20+09:00

【Promiseは規格？みたいなもの】

【Promiseとは】

Promiseはrejectedかfulfilledという結果が帰ってくることを約束してくれる。

そのため、それらに対するハンドリングがしやすいといったメリットがあると勉強していて感じた。実際、Node.jsの各メソッドをPromiseインスタンスに変換できるようなものが導入されたりとそのうちPromiseの規格に統一されるかもしれない。

【Promiseの挙動】

Promiseは、Promiseインスタンスを返す。

その時、Promiseインスタンスは最終的に、rejectedかfulfilledを返すが、それは以下のようにpendingな状態をreject()かresolve()で解決しないといけない。
         pending
　　　　　　　↓
　　　　　　／ ＼
    reject()   resolve()
       ↓         ↓
　 rejected     fulfilled    <=  これらの状態をsettledという
【Promiseインスタンスをsettled状態にしてみる】

まずPromiseはnew Promise() のようにして一度pendingな状態にする方法と、

pending状態を経ずに直接fulfilled、rejected状態にする2パターンある。
// 一度pendingにする
// settledにするには一度変数に入れて、setTimeoutで3000経過させるなどしないといけない
function asyncFunc(){
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            try{ 
                resolve('成功')
            }catch(err){
                reject(err)
        }},3000)
    })
}
console.log(asyncFunc()) => Promise { <pending> }

// 直接resolve、rejected
Promise.resolve('成功') => Promise { '成功' }
Promise.reject(new Error('エラー')) => Promise { <rejected> Error: エラー ~~(省略)
【settled状態を利用して次の処理をおこなう】

.then()、.catch()、を使えば、Promiseインスタンスがsettledになったら、実行するコールバック処理を設置できる。

以下の処理は、Promiseが1でfulfilled状態になり、その結果を.then()のnumで受け取っている。

Promiseでコールバックヘルが解決できるのはこういったことができるからだ。
Promise.resolve(1)
             .then(num => console.log('resolve', num))
上記の.then()は省略されており、第二引数には.then()で起きたエラーの処理を受け取れるようになっている。しかし、これは.then()が多くなると長くなる。

.catch()を最後につけることで.then()で起きたエラーを全て一箇所で受け取れる。
// 同じことをしている
Promise.resolve(1)
             .then(
                    num => console.log('resolve', num),
                    err => new Error('エラー')
             )

Promise.resolve(1)
             .then(num => console.log('resolve', num))
             .catch(err => new Error('エラー'))
【複数のPromiseを並行に処理してみる】

・ Promise.all　

中のPromiseインスタンスが全部fulfilledになったら、その値でfulfilledを返す。

これだと各処理が平行に実行されるので効率がいい。
const all = Promise.all(
    [1,Promise.resolve('成功'), Promise.resolve('fulfilled')]
)
all => Promise { [ 1, '成功', 'fulfilled' ] }
・Promise.allSettled

中のPromiseインスタンスがfulfilledかrejectedかに関わらずそれぞれの結果を返す。

とりあえず結果をきにせず平行に処理したい時に便利かも。
const allSettled = Promise.allSettled([
    Promise.resolve('成功'), Promise.reject(new Error('エラー'))
])
allSettled => Promise {[
    { status: 'fulfilled', value: '成功' },
    { status: 'rejected',
      reason: Error: エラー ~ (省略)
Node.jsでよく使うasync awaitもPromiseインスタンスをawaitの直前に置くことで実装できるように設計されているためPromiseの理解が重要。

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T13:49:47+09:00

Node.js で車とシリアル通信する

先日車が壊れたのを機に車について調べていたら OBD (On-board diagnostics) という診断機能を知りました。大抵の車には OBD のコネクタが搭載されていて、これに ELM327というマイコンを使った製品をつなぐと Bluetooth のシリアル通信などで簡単に情報をやりとりできるそうです。おもしろそうなので試してみました。

重要このポストと同じ方法で車の診断ログをリセットしたりすることもできます。診断ログが正しくない状態になると、修理の適切なタイミングなどがわからなくなるはずです。コマンドを車に送る前によく考えた上で自己責任で試してください。

ELM327 のドングルを手に入れる

これらの製品は Amazon 等で廉価に入手できるようです。全製品で固定っぽい Bluetooth の接続パスワードが書かれていたので念のため黒塗りにしました。

車のOBDポートを探す

運転席のどこかにある場合が多いようです。私の車はここにありました。

ここに購入した上記のドングル型デバイスを接続します。

通信方法を確認

送信

AT コマンドというものを送るとマイコンを操作することができるようです。今回は以下の2つのコマンドを使いました。

AT Z: 状態をリセットする

AT SP 0: OBDの通信プロトコルを自動で検出

通信プロトコルは様々なものがあるようですが、私の車で試した限りでは AT SP 0 の自動検出でうまく通信できました。

AT コマンドの他に OBD コマンドというものがあり、これで様々な OBD の情報を取得できました。Wikipedia にコマンドのリストがあったため、これを参照しました。

OBD コマンドは Mode と　PID から構成されています。現在のデータを読み取る 01 というモードを今回は使いました。取得できるデータごとに PID が振られており、例えば PID が 0C のエンジン回転数の情報を読み取る OBD コマンドは 010C になります。

受信

データは、４1 0C AA BB ... のようにスペース区切りの16進数の文字列で帰ってきます。1つめが Mode の値に40を足したもの、2つめが PID で、それ以降が実際のデータになります。例えばエンジン回転数の場合は値が4倍されているなど、それぞれ決まりがあるようです。

Node.js でシリアル通信をする

serialport というライブラリが著名そうだったので利用しました。

Node.js のランタイムでシリアルポートをオープンする TypeScript のコードはこんな感じ。ELM327 のデバイスに Bluetooth で接続した後に connect の関数を実行すると、非同期で SerialPort のインスタンスが得られます。
import SerialPort from 'serialport'

const DEVICE_PATH = '/dev/tty.OBDII-SPPslave'
export const connect = () => new Promise<SerialPort>((resolve, reject) => {
    const port = new SerialPort(DEVICE_PATH, { baudRate: 9600, autoOpen: false })
    console.log(`[SP] opening on ${DEVICE_PATH}..`)
    port.open((error) => {
        if(error) {
            console.log('[SP] port opening error.')
            reject(error)
        } else {
            console.log('[SP] port opened.')
            resolve(port)
        }
    })
})
ポートに書き込むには write メソッドを使います。コマンドのデリミタはキャリッジリターンなので注意してください。
// `AT Z` の AT コマンドを送出
port.write('AT Z\r')
データはイベントリスナーを使って取得できます。
文字列を処理して、目的の値を抽出します。
port.on('data', (data: string) => {
    const [mode, pid, ...values] = data.split(' ')

    let modeNum
    try {
        modeNum = parseInt(mode, 16) - 40  
    } catch {
        return
    }

    if(modeNum === 1) {
        const hexValue = parseInt(values.filter(value => value !== '').join(''), 16)
        if(pid === '0C') {
            console.log('EngineRPM: ' + hexValue / 4)
        }
    }
})
WebSocket でデータをブラウザに送信できるようにする

上記でデータが取得できる準備が整ったので、あとは WebSocket を使ってブラウザにデータを送ってみます。ws というライブラリを使います。

WebSocket サーバーを立ち上げるコードはこんな感じ。 createSocket の関数をコールすると非同期で WebSocket のインスタンスが得られます。
import WebSocket from 'ws'

export const createSocket = () => new Promise<WebSocket>((resolve, reject) => {
    console.log('[WS] connecting...')
    const wss = new WebSocket.Server({ port: 8081 })
    wss.on('connection', (socket) => {
        console.log('[WS] connected.')
        resolve(socket)
    })
})
WebSocket のインスタンスを使って、シリアル通信で得られたデータを送ります。上記のシリアル通信のイベントリスナーに socket.send(data) を差し込めば OK です。

クライアント側は、こんな感じ。
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Document</title>
    <style>
        #display {
            width: 500px;
            height: 100px;
            font-size: 2em;
        }
    </style>
</head>
<body>
    <textarea id="display"></textarea>
    <script>
        const ws = new WebSocket('ws://localhost:8081')
        const display = document.getElementById('display')

        let currentData = {}

        ws.onmessage = (event) => {
           const data = JSON.parse(event.data)
            display.value = "エンジン回転数: " + data.engineRPM + "rpm"
        }
    </script>
</body>
</html>
動作させる

以上で全ての材料が揃ったので、これを組み込んでいきます。今回は Mac 上で以下の全てのプロセスを立ち上げて試してみました。

車とシリアル通信をする WebSocket サーバー

クライアントを表示するウェブサーバー

また、エンジン回転数以外にも現在の運転速度と冷却水温度も取得してみました。

https://youtu.be/jtPIO3J6cEs

動画を撮りながら走ってみると、いい感じにデータが取れているようです✌️

上記のコードは以下のリポジトリにあります。
https://github.com/kamataryo/parse-obd-serial

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T12:51:06+09:00

Node.js(express)でpostgresSQLのSSL認証が通らないことについて

はじめに

店舗予約の受付をするLineBotの開発をするために
Node.js(express)を開発言語にしました。

PostgresSQLでDB作成をしたさいに
SSL接続が原因でエラーとバトルした件について解説します。

少しでもお役に立てれば幸いです。

誤った情報だと感じましたら教えてください！

開発環境

(1)macOS 10.15.7
(2)Node.js 12.19.0
(3)express 4.17.1
(4)line/bot-sdk" 7.2.0
(5)Postgres 8.5.1
(6)Heroku

エラー内容
index.js
const { Client } = require('pg');

//Postgres環境変数を設定//

const connection = new Client({
  user: process.env.PG_USER,
  host: process.env.PG_HOST,
  database: process.env.PG_DATABASE,
  password: process.env.PG_PASSWORD,
  port: ****
});
connection.connect();

//クエリ文//

const userTable = {
    text:'CREATE TABLE IF NOT EXISTS users (id SERIAL NOT NULL, line_uid VARCHAR(255), display_name VARCHAR(255), timestamp VARCHAR(255), trigger SMALLINT, remedy SMALLINT, pelvis SMALLINT);'
 };

//クエリを実行するためのコード//

connection.query(userTable)
   .then(()=>{
       console.log('table users created successfully!!');
   })
   .catch(e => console.log(e));
テーブルができているか確認をするために
ターミナル
$ heroku pg:psql
データベースモードになったら
ターミナル
DATABASE=> select * from users; 
ここで怒られます。 orz
ターミナル
ERROR:  relation "users" does not exist 　//"users"との関係性がありません

LINE 1: select * from "users";
((((；ﾟДﾟ)))))))

解決策

エラー文を検索しても出てくる記事が

１、select * from "users"とダブルクォーテーションで囲め！！

２、大文字と小文字が〜〜〜

など変更しても解決にならず。

どうしても分からず質問したところ
Postgres環境変数を修正しましょう！！これで解決できます！！と素敵なアドバイスをもらいました♫
index.js
//Postgres環境変数を設定//

const connection = new Client({
  connectionString: process.env.DATABASE_URL,
  ssl: {
    rejectUnauthorized: false    //SSL接続なくても許可するよーと宣言
  }
});
connection.connect();
コードの変更をしたので確認します！！！

先程と同じようにデータベースモードにします。
ターミナル
$ heroku pg:psql
ターミナル
DATABASE=> select * from users;
上記にコードを修正した結果
↓
ターミナル
ファイル名::DATABASE=> select * from users;
 id | line_uid | display_name | timestamp | trigger | remedy | pelvis 
----+----------+--------------+-----------+---------+--------+--------
(0 rows)
おけ?

考察

今回のエラーはSSL接続が許可されておらず認証されないことによって起きたと考えています。

(1)最近仕様が変更になった出来事なのか？

(2)SSL接続がデフォルトに変更されたのか？

参考文献が見つからず原因がわかる方がいらっしゃいましたら、ご教授ください。

　 Tweet
Qiitaで続きを読む

投稿日：2021-01-17T11:48:30+09:00

M5Core2のLCDにWebページのスクリーンショットを表示する

M5Core2のLCDにいろんな情報を表示する際に、画面レイアウトを試行錯誤しながらコンパイル・書き込み・実行を繰り返すのは手間なので、HTMLで画面を作成してそのスクリーンショットをM5Core2のLCDに表示するようにします。

もろもろのソースコードをGitHubに上げておきました。

poruruba/WebSnapshot
　https://github.com/poruruba/WebSnapshot

スクリーンショット生成

スクリーンショットには「puppeteer」を使います。

puppeteer/puppeteer
　https://github.com/puppeteer/puppeteer

(参考)呼び出し方
　https://github.com/puppeteer/puppeteer/blob/v5.5.0/docs/api.md

サーバの実装は以下の通りです。