import jp.osdn.gokigen.thetathoughtshutter.theta.ThetaHardwareControl
import jp.osdn.gokigen.thetathoughtshutter.theta.ThetaSetupBluetoothSPP
import jp.osdn.gokigen.thetathoughtshutter.theta.operation.IOperationCallback
+import jp.osdn.gokigen.thetathoughtshutter.theta.status.ThetaCameraStatusWatcher
import java.lang.Exception
class MainActivity : PluginActivity(), IBluetoothScanResult, IDetectSensingReceiver
{
private val thetaHardwareControl = ThetaHardwareControl(this)
private val thetaCaptureControl = ThetaCaptureControl("http://localhost:8080")
+ private val thetaStatusWatcher = ThetaCameraStatusWatcher("http://localhost:8080")
private val applicationStatus : MyApplicationStatus = MyApplicationStatus()
private val bluetoothConnection = MindWaveConnection(this, BrainwaveDataHolder(this), this)
{
if (keyCode == KeyReceiver.KEYCODE_WLAN_ON_OFF) // Wirelessボタン
{
- if (applicationStatus.status == MyApplicationStatus.Status.Initialized)
+ if ((applicationStatus.status == MyApplicationStatus.Status.Initialized)||
+ (applicationStatus.status == MyApplicationStatus.Status.FailedInitialize))
{
// Bluetooth SPPで EEGに接続する
connectToEEG()
}
}
-/*
if (keyCode == KeyReceiver.KEYCODE_MEDIA_RECORD) // Modeボタン
{
- when (applicationStatus.status) {
- MyApplicationStatus.Status.Searching -> {
- // ダミー処理 (EEG接続完了)
- applicationStatus.status = MyApplicationStatus.Status.Connected
- }
- MyApplicationStatus.Status.Scanning -> {
- // ダミー処理 (高まっている状態)
- applicationStatus.status = MyApplicationStatus.Status.Syncing
- }
- MyApplicationStatus.Status.Syncing -> {
- // ダミー処理 (高まるのを待っている状態)
- applicationStatus.status = MyApplicationStatus.Status.Scanning
- }
- else -> {
- // ダミー処理 (初期化完了)
- applicationStatus.status = MyApplicationStatus.Status.Initialized
- }
- }
+ // 接続エラーにする
+ applicationStatus.status = MyApplicationStatus.Status.FailedInitialize
}
+/*
if (keyCode == KeyReceiver.KEYCODE_FUNCTION) // Fnボタン (Z1のみ)
{
}
+
if (keyCode == KeyReceiver.KEYCODE_CAMERA) // Shutterボタン
{
// Bluetoothデバイスが見つかった！
applicationStatus.status = MyApplicationStatus.Status.Connected
updateStatus(applicationStatus.status)
+
+ // 周期実行
+ thetaStatusWatcher.startStatusWatch()
}
catch (e : Exception)
{
override fun detectAttention()
{
- Log.v(TAG, " ===== DETECT ATTENTION =====")
+ //Log.v(TAG, " ===== DETECT ATTENTION =====")
applicationStatus.status = MyApplicationStatus.Status.Syncing
updateStatus(applicationStatus.status)
}
override fun lostAttention()
{
- Log.v(TAG, " ===== LOST ATTENTION =====")
+ //Log.v(TAG, " ===== LOST ATTENTION =====")
applicationStatus.status = MyApplicationStatus.Status.Scanning
updateStatus(applicationStatus.status)
}
override fun detectAttentionThreshold()
{
- Log.v(TAG, " ===== DETECT ATTENTION THRESHOLD =====")
+ //Log.v(TAG, " ===== DETECT ATTENTION THRESHOLD =====")
try
{
// 静止画の撮影！
override fun detectMediationThreshold()
{
- Log.v(TAG, " ===== DETECT MEDIATION THRESHOLD =====")
+ //Log.v(TAG, " ===== DETECT MEDIATION THRESHOLD =====")
}
-
}
-
-//
-// -----------------------------------------------------
-// LED1 : 電源ランプ
-// LED2 : カメラステータス ランプ(レンズとマイクの間)
-// LED3 : ワイヤレスマーク ランプ
-// LED4 : キャプチャーモード (カメラ)
-// LED5 : キャプチャーモード (ムービー)
-// LED6 : キャプチャーモード (LIVEストリーミング)
-// LED7 : ビデオ録画 ランプ
-// LED8 : メモリ警告ランプ
-//
-// BTN1 : 電源ボタン
-// BTN2 : ワイヤレスボタン
-// BTN3 : モードボタン
-// SHUT : シャッターボタン
-// -----------------------------------------------------
-//
-// [制御可能なLED]
-// - LED3～LED8 : カラー : "blue", "green", "red", "cyan", "magenta", "yellow", "white"
-// - ブリンク間隔 : 1～2000 msec
-//
-// [KeyCode]
-// - 27 : Shutter Button
-// - 130 : Mode Button
-// - 284 : Wireless Button
-// - 119 : Fn Button (Z1 Only)
-//
-//
-// http://localhost:8080/
-//
package jp.osdn.gokigen.thetathoughtshutter.brainwave
import android.util.Log
-import java.util.*
class BrainwaveDataHolder(private val receiver: IDetectSensingReceiver? = null, maxBufferSize: Int = 16000) : IBrainwaveDataReceiver
{
try {
var endPosition = currentPosition - 1
if (currentPosition > size) {
- return Arrays.copyOfRange(valueBuffer, endPosition - size, endPosition)
+ return valueBuffer.copyOfRange(endPosition - size, endPosition)
}
if (!bufferIsFull) {
- return Arrays.copyOfRange(valueBuffer, 0, endPosition)
+ return valueBuffer.copyOfRange(0, endPosition)
}
if (currentPosition == 0) {
endPosition = maxBufferSize - 1
- return Arrays.copyOfRange(valueBuffer, endPosition - size, endPosition)
+ return valueBuffer.copyOfRange(endPosition - size, endPosition)
}
val remainSize = size - (currentPosition - 1)
- val size0: IntArray = Arrays.copyOfRange(valueBuffer, 0, currentPosition - 1)
- val size1: IntArray = Arrays.copyOfRange(
- valueBuffer,
- maxBufferSize - 1 - remainSize, maxBufferSize - 1
- )
+ val size0: IntArray = valueBuffer.copyOfRange(0, currentPosition - 1)
+ val size1: IntArray = valueBuffer.copyOfRange(maxBufferSize - 1 - remainSize, maxBufferSize - 1)
replyData = IntArray(size)
System.arraycopy(size1, 0, replyData, 0, size1.size)
System.arraycopy(size0, 0, replyData, size1.size, size0.size)
--- /dev/null
+package jp.osdn.gokigen.thetathoughtshutter.theta.status
+
+import android.util.Log
+import jp.osdn.gokigen.thetathoughtshutter.utils.SimpleHttpClient
+import org.json.JSONObject
+
+class ThetaCameraStatusWatcher(private val executeUrl : String = "http://192.168.1.1", private val statusNotify : IStatusNotify? = null) : ICameraStatusWatcher, IThetaStatusHolder
+{
+ private val httpClient = SimpleHttpClient()
+ private var whileFetching = false
+ private var currentIsoSensitivity : Int = 0
+ private var currentBatteryLevel : Double = 0.0
+ private var currentAperture : Double = 0.0
+ private var currentShutterSpeed : Double = 0.0
+ private var currentExposureCompensation : Double = 0.0
+ private var currentCaptureMode : String = ""
+ private var currentExposureProgram : String = ""
+ private var currentCaptureStatus : String = ""
+ private var currentWhiteBalance : String = ""
+ private var currentFilter : String = ""
+
+ override fun startStatusWatch()
+ {
+ if (whileFetching)
+ {
+ Log.v(TAG, "startStatusWatch() already starting.")
+ return
+ }
+ whileFetching = true
+
+ try
+ {
+ val thread = Thread {
+ try
+ {
+ val getOptionsUrl = "$executeUrl/osc/commands/execute"
+ val getStateUrl = "$executeUrl/osc/state"
+
+ val postDataCaptureMode = "{\"name\":\"camera.getOptions\",\"parameters\":{\"timeout\":0, \"optionNames\" : [ \"captureMode\"] }}"
+ val postDataImage = "{\"name\":\"camera.getOptions\",\"parameters\":{\"timeout\":0, \"optionNames\" : [ \"aperture\",\"captureMode\",\"exposureCompensation\",\"exposureProgram\",\"iso\",\"shutterSpeed\",\"_filter\",\"whiteBalance\"] }}"
+ val postDataVideo = "{\"name\":\"camera.getOptions\",\"parameters\":{\"timeout\":0, \"optionNames\" : [ \"aperture\",\"captureMode\",\"exposureCompensation\",\"exposureProgram\",\"iso\",\"shutterSpeed\",\"whiteBalance\"] }}"
+ Log.v(TAG, " >>>>> START STATUS WATCH : $getOptionsUrl")
+ while (whileFetching)
+ {
+ val response0: String? = httpClient.httpPostWithHeader(getOptionsUrl, postDataCaptureMode, null, "application/json;charset=utf-8", timeoutMs)
+ if (!(response0.isNullOrEmpty()))
+ {
+ // 設定データ受信、解析する
+ checkStatus0(response0)
+ }
+ val postData = if (currentCaptureMode != "image") { postDataVideo } else { postDataImage }
+ val response1: String? = httpClient.httpPostWithHeader(getOptionsUrl, postData, null, "application/json;charset=utf-8", timeoutMs)
+ if (!(response1.isNullOrEmpty()))
+ {
+ // 設定データ受信、解析する
+ checkStatus1(response1)
+ }
+ val response2: String? = httpClient.httpPostWithHeader(getStateUrl, "", null, "application/json;charset=utf-8", timeoutMs)
+ if (!(response2.isNullOrEmpty()))
+ {
+ // ステータスデータ受信、解析する
+ checkStatus2(response2)
+ }
+ try
+ {
+ // ちょっと休む
+ Thread.sleep(loopWaitMs)
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+ thread.start()
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+
+ private fun checkStatus0(response: String)
+ {
+ try
+ {
+ //Log.v(TAG, " STATUS0 : $response")
+ val stateObject = JSONObject(response).getJSONObject("results").getJSONObject("options")
+ try
+ {
+ val captureMode = stateObject.getString(THETA_CAPTURE_MODE)
+ if (captureMode != currentCaptureMode)
+ {
+ Log.v(TAG, " CapMode : $currentCaptureMode -> $captureMode")
+ currentCaptureMode = captureMode
+ statusNotify?.changedCaptureMode(captureMode)
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+ catch (e : Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+
+ private fun checkStatus1(response: String)
+ {
+ try
+ {
+ //Log.v(TAG, " STATUS1 : $response")
+ val stateObject = JSONObject(response).getJSONObject("results").getJSONObject("options")
+ try
+ {
+ val exposureCompensation = stateObject.getDouble(THETA_EXPOSURE_COMPENSATION)
+ if (exposureCompensation != currentExposureCompensation)
+ {
+ Log.v(TAG, " XV : $currentExposureCompensation => $exposureCompensation")
+ currentExposureCompensation = exposureCompensation
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ try
+ {
+ val whiteBalance = stateObject.getString(THETA_WHITE_BALANCE)
+ if (whiteBalance != currentWhiteBalance)
+ {
+ Log.v(TAG, " WB : $currentWhiteBalance => $whiteBalance")
+ currentWhiteBalance = whiteBalance
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ try
+ {
+ val exposureProgram = stateObject.getString(THETA_EXPOSURE_PROGRAM)
+ if (exposureProgram != currentExposureProgram)
+ {
+ currentExposureProgram = exposureProgram
+
+ var mode = ""
+ when (currentExposureProgram) {
+ "1" -> mode = "Manual"
+ "2" -> mode = "Normal"
+ "3" -> mode = "Aperture"
+ "4" -> mode = "Shutter"
+ "9" -> mode = "ISO"
+ }
+ statusNotify?.changedExposureProgram(mode)
+ Log.v(TAG, " ExposureProgram : $mode")
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ if (currentCaptureMode == "image")
+ {
+ try
+ {
+ val filterValue = stateObject.getString(THETA_FILTER)
+ if (filterValue != currentFilter)
+ {
+ Log.v(TAG, " FILTER : $currentFilter -> $filterValue")
+ currentFilter = filterValue
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ }
+ else
+ {
+ currentFilter = ""
+ }
+
+ try
+ {
+ val isoSensitivity = stateObject.getInt(THETA_ISO_SENSITIVITY)
+ if (isoSensitivity != currentIsoSensitivity)
+ {
+ Log.v(TAG, " ISO : $currentIsoSensitivity -> $isoSensitivity")
+ currentIsoSensitivity = isoSensitivity
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ try
+ {
+ val aperture = stateObject.getDouble(THETA_APERTURE)
+ if (aperture != currentAperture)
+ {
+ Log.v(TAG, " A : $currentAperture -> $aperture")
+ currentAperture = aperture
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ try
+ {
+ val shutterSpeed = stateObject.getDouble(THETA_SHUTTER_SPEED)
+ if (shutterSpeed != currentShutterSpeed)
+ {
+ Log.v(TAG, " SS : ${convertShutterSpeedString(currentShutterSpeed)}")
+ currentShutterSpeed = shutterSpeed
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ }
+ catch (ee: Exception)
+ {
+ ee.printStackTrace()
+ }
+ }
+
+ private fun convertShutterSpeedString(shutterSpeed : Double) : String
+ {
+ var inv = 0.0
+ var stringValue = ""
+ try
+ {
+ if (shutterSpeed < 1.0)
+ {
+ inv = 1.0 / shutterSpeed
+ }
+ if (inv < 2.0) // if (inv < 10.0)
+ {
+ inv = 0.0
+ }
+ if (inv > 0.0f)
+ {
+ // シャッター速度を分数で表示する
+ var intValue = inv.toInt()
+ val modValue = intValue % 10
+ if (modValue == 9 || modValue == 4)
+ {
+ // ちょっと格好が悪いけど...切り上げ
+ intValue++
+ }
+ stringValue = "1/$intValue"
+ }
+ else
+ {
+ // シャッター速度を数値(秒数)で表示する
+ stringValue = "${shutterSpeed}s "
+ }
+ }
+ catch (e : Exception)
+ {
+ e.printStackTrace()
+ }
+ return (stringValue)
+ }
+
+ private fun checkStatus2(response: String)
+ {
+ try
+ {
+ //Log.v(TAG, " STATUS2 : $response")
+ val stateObject = JSONObject(response).getJSONObject("state")
+ try
+ {
+ val captureStatus = stateObject.getString(THETA_CAPTURE_STATUS)
+ if (captureStatus != currentCaptureStatus)
+ {
+ Log.v(TAG, " CapStatus : $currentCaptureStatus -> $captureStatus")
+ currentCaptureStatus = captureStatus
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+ try
+ {
+ val batteryLevel = stateObject.getDouble(THETA_BATTERY_LEVEL)
+ if (batteryLevel != currentBatteryLevel)
+ {
+ Log.v(TAG, " BATTERY : $currentBatteryLevel => $batteryLevel")
+ currentBatteryLevel = batteryLevel
+ updateRemainBattery(currentBatteryLevel)
+ }
+ }
+ catch (e: Exception)
+ {
+ e.printStackTrace()
+ }
+
+ }
+ catch (ee: Exception)
+ {
+ ee.printStackTrace()
+ }
+ }
+
+ private fun updateRemainBattery(percentageDouble: Double)
+ {
+ try
+ {
+ val percentage = kotlin.math.ceil(percentageDouble * 100.0).toInt()
+ Log.v(TAG, "BATTERY : $percentage%")
+ }
+ catch (ee: java.lang.Exception)
+ {
+ ee.printStackTrace()
+ }
+ }
+
+ override fun stopStatusWatch()
+ {
+ whileFetching = false
+ }
+
+ companion object
+ {
+ private val TAG = ThetaCameraStatusWatcher::class.java.simpleName
+ private const val timeoutMs = 3300
+ private const val loopWaitMs : Long = 35000 // 35sec. おきに状態を取得
+
+ private const val THETA_BATTERY_LEVEL = "batteryLevel"
+ private const val THETA_CAPTURE_STATUS = "_captureStatus"
+
+ private const val THETA_APERTURE = "aperture"
+ private const val THETA_CAPTURE_MODE = "captureMode"
+ private const val THETA_EXPOSURE_COMPENSATION = "exposureCompensation"
+ private const val THETA_EXPOSURE_PROGRAM = "exposureProgram"
+ private const val THETA_ISO_SENSITIVITY = "iso"
+ private const val THETA_SHUTTER_SPEED = "shutterSpeed"
+ private const val THETA_WHITE_BALANCE = "whiteBalance"
+ private const val THETA_FILTER = "_filter"
+ }
+
+ override var captureMode: String
+ get() = currentCaptureMode
+ set(value) { currentCaptureMode = value }
+}
OSDN Git Service
