bool rtc_joined_room = false;
static void OnRtcMessage(RtcMessage* msg) 
{
	printf("myListener got Message: %d\n", msg->msgType);
	switch (msg->msgType) {
	case RTC_MESSAGE_ROOM_EVENT_LOGIN_OK: {
		printf("Login ok!\n");
	} break;
	case RTC_MESSAGE_ROOM_EVENT_LOGIN_ERROR: {
		printf("Login error!\n");
	} break;
	case RTC_MESSAGE_ROOM_EVENT_LOGIN_TIMEOUT: {
		printf("Login timeout!\n");
	} break;
	case RTC_MESSAGE_ROOM_EVENT_CONNECTION_ERROR: {
		printf("Connection error!\n");
	} break;
	case RTC_MESSAGE_ROOM_EVENT_REMOTE_COMING: {
		printf("Feed coming!\n");
	} break;
	case RTC_ROOM_EVENT_ON_PUBLISHER_JOINED_ROOM: {
		printf("Publisher joined room!\n");
		rtc_joined_room = true;
	} break;
	case RTC_ROOM_EVENT_ON_USER_MESSAGE: {
		printf("user msg callback:%s\n", msg->extra_info);
	} break;
	case RTC_ROOM_EVENT_ON_USER_JOINED_ROOM: {
		printf("User joined room!\n");
	} break;
	case RTC_MESSAGE_MEDIA_SIGNAL_ESTABLISH_OK: {
		printf("Media signal established ok!\n");
	} break;
	case RTC_MESSAGE_MEDIA_SIGNAL_ESTABLISH_ERROR: {
		printf("Media signal established error!\n");
	} break;
	case RTC_MESSAGE_MEDIA_SIGNAL_RECEIVE_FISRT_AUDIO: {
		printf("It received audio yet!\n");
	} break;
	case RTC_MESSAGE_MEDIA_SIGNAL_RECEIVE_FISRT_VIDEO: {
		printf("It received video yet!\n");
	} break;
	case RTC_MESSAGE_MEDIA_SIGNAL_NO_RTP_STREAM_TIMEOUT: {
		printf("Did't receive rtp stream because of timeout!\n");
	} break;
	case RTC_MESSAGE_ROOM_EVENT_REMOTE_LEAVING: {
		printf("Feed leaving!\n");
	} break;
	case RTC_MESSAGE_STATE_STREAM_UP: {
		printf("Stream up, send/got video now\n");
	} break;
	default:
		break;
	}
}
void brtc_video_call_put_image(int width, int height, const unsigned char *src, 
    int is_semi, int img_type)  //回调解码后的视频数据显示
{
    printf("put image");
}

const char *s_url = "ws://rtc2.exp.bcelive.com:8186/janus";
static void *client = NULL;
int main(int argc, char* argv[]) 
{
	bool ret =false;
	const char appId[] = "APPID_GET_FROM_BAIDU"; //please get a appId from baidu
	const char token[] = "no_token";
	const char room_name[] = "8000";
	const char user_id[] = "1008";
	if(client == NULL) {
		client = brtc_create_client();
		if (client == NULL) {
			printf("brtc_create_client failed\n");
			return -1;
		}
	}

	if (client) {
		brtc_register_message_listener(client, OnRtcMessage);
		brtc_set_server_url(client, s_url);
		ret = brtc_init_sdk(client, appId, room_name, user_id, token, NULL);
		if (!ret) {
			printf("brtc_init_sdk failed\n");
			return -1;
		}
		while (!rtc_joined_room);

		ret = brtc_login_room(client);
		if (!ret) {
			printf("brtc_login_room failed\n");
			brtc_deInit_sdk(client);
			brtc_destroy_client(client);
			if(client)
				client = NULL;
			return -1;
		}

		while (true) {
			printf("Please input q to Quit.\n");
			char commandid[512];
			memset(commandid, 0, sizeof(commandid));
			int ret = scanf("%s", commandid);
			printf("scanf %d.\n", ret);
			if (ret < 0) {
				continue;
			}
			if (commandid[0] == 'q') {
            break;
         }
		}

		ret = brtc_logout_room(client);
		if (!ret) {
			printf("brtc_logout_room failed\n");
			brtc_deInit_sdk(client);
			brtc_destroy_client(client);
			if(client)
				client = NULL;
			return -1;
		}
		brtc_deInit_sdk(client);
		brtc_destroy_client(client);
		if(client)
			client = NULL;
		rtc_joined_room = false;
	}

	return 0;
}