MatrixApplicationServiceClient.java

/*
 * matrix-java-sdk - Matrix Client SDK for Java
 * Copyright (C) 2017 Maxime Dor
 *
 * https://max.kamax.io/
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

package io.kamax.matrix.client.as;

import io.kamax.matrix.MatrixID;
import io.kamax.matrix.client.MatrixClientContext;
import io.kamax.matrix.client._MatrixClient;
import io.kamax.matrix.client.regular.MatrixHttpClient;
import io.kamax.matrix.hs._MatrixHomeserver;
import io.kamax.matrix.json.VirtualUserRegistrationBody;

import org.apache.http.client.methods.HttpPost;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.net.URI;

public class MatrixApplicationServiceClient extends MatrixHttpClient implements _MatrixApplicationServiceClient {

    private Logger log = LoggerFactory.getLogger(MatrixApplicationServiceClient.class);

    public MatrixApplicationServiceClient(_MatrixHomeserver hs, String token, String localpart) {
        super(new MatrixClientContext(hs, new MatrixID(localpart, hs.getDomain()), token));
    }

    private MatrixHttpClient createClient(String localpart) {
        return new MatrixHttpClient(
                new MatrixClientContext(getHomeserver(), getMatrixId(localpart), getAccessTokenOrThrow(), true));
    }

    @Override
    public _MatrixClient createUser(String localpart) {
        log.debug("Creating new user {}", localpart);
        URI path = getClientPathWithAccessToken("/register");
        HttpPost req = new HttpPost(path);
        req.setEntity(getJsonEntity(new VirtualUserRegistrationBody(localpart)));
        execute(req);

        return createClient(localpart);
    }

    @Override
    public _MatrixClient getUser(String localpart) {
        return createClient(localpart);
    }

}