【Spring-boot】Nature Remoをローカル環境から操作する【React】

Last updated at 2021-03-11Posted at 2021-03-08

NatureRemo

テレビやエアコン等の赤外線操作ができる家電をスマホやスマートスピーカー等から操作できるようにするデバイス。
Nature Remo（ネイチャーリモ）

概要

たまにAWSの障害が波及してNatureRemoが使えなくなる事象が発生する。
こうなってしまうと、いつもはAlexaで操作していた家電の切り替えがリモコンじゃないと操作できなくなる。

昨晩深夜からのNature Remoのシステム障害ですが、AWS（アマゾンウェブサービス）の障害に起因しており、現時点で一部改善はしておりますが、完全復旧までにはもう少し時間がかかる状況です。
ご不便をおかけて大変申し訳ございません。今しばらく復旧をお待ちいただけますと幸いです。
— Nature株式会社 (@NatureRemo_JP) November 25, 2020

また、NatureRemoはLocal環境からアクセスできるAPIを用意していて赤外線信号の取得と実行のみができる仕組みがある。
これを利用してローカル環境だけでNatureRemoを操作できるアプリの開発を行う。
赤外線信号を保存する仕組みは備わっていない様子。こちらも合わせて実装していく。
Nature Inc

環境整理

サーバ: Spring-boot
フロントエンド: React.js
DB: Cassandra

サーバサイド

akapo001/local-remo
サーバサイドはREST APIをSpringBootで実装する。
firebaseで実装しても良かったが次のアサイン予定のプロジェクトでSpringを使う予定なので思い出すのを兼ねて自前で実装を行った。
DBはRDBで実装するとNatureRemoから取得する赤外線情報のフォーマット的に大変そうだったのでNoSQLのCassandraを使用してデータの保存を行う。
CassandraはDockerのイメージを利用して構築する。

API一覧

信号取得
- NatureRemoから赤外線信号を取得する
- NatureRemoに赤外線信号を当てたあとこのAPIを実行すると赤外線情報を取得できる
信号保存
- 信号取得で取得した赤外線情報をそのままこのAPIのBodyにわたすとサーバ側のCassandraに保存するAPI
- パスパラメータに信号に紐付ける名前を指定する。
信号一覧取得
- Cassandraに保存されている信号の一覧を取得する。
信号実行
- 信号一覧で取得したデータから実行したい信号のIDを設定してリクエストするとNatureRemoを通して家電の操作ができる。
信号削除
- 信号一覧で取得したデータから削除したい信号のIDを設定してリクエストするとCassandraからデータを削除する。

SpringからCassandraへの接続設定

SpringからCassandra呼び出しをする処理のサンプルがなくて苦労したが下記のクラスをConfigrationクラスとして定義することで接続ができた。
Keyspaceやホスト、ポート等は設定ファイルから読み取る。

@Configuration
@EnableCassandraRepositories(cassandraTemplateRef = "cassandraTemplate")
public class CassandraConfig extends AbstractCassandraConfiguration {
    @Value("${spring.data.cassandra.username}")
    private String username;

    @Value("${spring.data.cassandra.password}")
    private String password;

    @Value("${spring.data.cassandra.keyspace-name}")
    private String keyspaceName;

    @Value("${spring.data.cassandra.contact-points}")
    private String contactPoints;

    @Value("${spring.data.cassandra.port}")
    private int port;


    @Override
    @Primary
    @Bean
    public CassandraAdminTemplate cassandraTemplate() {
        CqlSession session = CqlSession.builder().withKeyspace(keyspaceName).build();
        return new CassandraAdminTemplate(session);
    }

    // ポート番号の設定
    @Override
    @Bean(name = "Port")
    public int getPort() {
        return port;  // デフォルトは9042
    }

    // キースペースの設定
    @Override
    @Bean(name = "KeySpace")
    protected String getKeyspaceName() {
        return keyspaceName;
    }
    
}

Cassandra操作

こちらも最新のバージョンだとAPIのIFが違うらしくなかなかアクセスができなかったので以下にサンプルを記載

@Service
public class CassandraService {

    @Autowired
    CassandraAdminTemplate cassandraTemplate;

    public SignalTable insert(Signal signal, String name) {
        return cassandraTemplate.insert(new SignalTable(Uuids.timeBased(), name, signal));
    }

    public List<SignalTable> selectAll() {
        SimpleStatement select = QueryBuilder.selectFrom("signal").all().build();
        return cassandraTemplate.select(select, SignalTable.class);
    }

    public SignalTable select(String id) {
        UUID uuid = UUID.fromString(id);
        return cassandraTemplate.selectOneById(uuid, SignalTable.class);
    }

    public String delete(String id) throws NotFoundSignal {
        UUID uuid = UUID.fromString(id);
        Boolean res = cassandraTemplate.deleteById(uuid, SignalTable.class);
        if(!res) throw new NotFoundSignal("信号が見つかりませんでした");

        return id;
    }

}

CORS対策

ローカルのフロントエンドからローカルに別途立てたサーバを呼び出したところ下記のエラーが出た。

The value of the 'Access-Control-Allow-Credentials' header in the response is '' which must be 'true' when the request's credentials mode is 'include'. The credentials mode of requests initiated by the XMLHttpRequest is controlled by the withCredentials attribute.

controllerクラスにCrossOriginアノテーションを追加してやることで回避できた。
デフォルトだとすべてのアクセスを許可する。

@RestController
@CrossOrigin
public class SignalController {
    @Autowired
    SignalService signalService;
    @Autowired
    CassandraService cassandraService;

    @GetMapping("/signal")
    Signal getSignal() {
        return signalService.fetchSignal();
    }

    @PostMapping("/signal")
    Signal sendSignal(@RequestBody SendSignal sendSignal) {
        Signal signal = cassandraService.select(sendSignal.getId()).getSignal();
        return signalService.sendSignal(signal);
    }

    @PostMapping("/signal/{name}")
    SignalTable  postSignal(@RequestBody Signal signal, @PathVariable String name) {return cassandraService.insert(signal, name);}

    @GetMapping("/all-signal")
    List<SignalTable> getAllSignal() { return cassandraService.selectAll();}

    @DeleteMapping("/signal/{id}")
    SimpleResponse deleteSignal(@PathVariable String id) throws NotFoundSignal {
        System.out.println(id);
        cassandraService.delete(id);
        return new SimpleResponse("削除成功");
    }
}