Release: v1.0.0

Author: make1986

Example/KWSExample/KWSExample.xcodeproj/project.pbxproj

@@ -0,0 +1,11 @@
+{
+  "colors" : [
+    {
+      "idiom" : "universal"
+    }
+  ],
+  "info" : {
+    "author" : "xcode",
+    "version" : 1
+  }
+}

Example/KWSExample/KWSExample.xcodeproj/project.xcworkspace/contents.xcworkspacedata

@@ -0,0 +1,35 @@
+{
+  "images" : [
+    {
+      "idiom" : "universal",
+      "platform" : "ios",
+      "size" : "1024x1024"
+    },
+    {
+      "appearances" : [
+        {
+          "appearance" : "luminosity",
+          "value" : "dark"
+        }
+      ],
+      "idiom" : "universal",
+      "platform" : "ios",
+      "size" : "1024x1024"
+    },
+    {
+      "appearances" : [
+        {
+          "appearance" : "luminosity",
+          "value" : "tinted"
+        }
+      ],
+      "idiom" : "universal",
+      "platform" : "ios",
+      "size" : "1024x1024"
+    }
+  ],
+  "info" : {
+    "author" : "xcode",
+    "version" : 1
+  }
+}

Example/KWSExample/KWSExample.xcodeproj/project.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -0,0 +1,6 @@
+{
+  "info" : {
+    "author" : "xcode",
+    "version" : 1
+  }
+}

Example/KWSExample/KWSExample/Assets.xcassets/AccentColor.colorset/Contents.json

@@ -0,0 +1,94 @@
+//
+//  AudioStreamer.swift
+//  KWSExample
+//
+//  Created by Marat Zainullin on 12/06/2025.
+//
+
+import Foundation
+import AVFoundation
+
+final class AudioStreamer {
+    private let engine = AVAudioEngine()
+    private let inputBus: AVAudioNodeBus = 0
+    private let sampleRate: Double = 16000
+    private let frameLength: Double = 3200
+
+    public var onBuffer: (([Double]) -> Void)?
+    
+    
+    init() {
+        let inputNode = engine.inputNode
+        let inputFormat = inputNode.outputFormat(forBus: inputBus)
+        
+        
+        let outputFormat = AVAudioFormat(commonFormat: .pcmFormatFloat32, sampleRate: sampleRate, channels: 1, interleaved: true)!
+        
+        let converter = AVAudioConverter(from: inputFormat, to: outputFormat)!
+
+        inputNode.installTap(onBus: inputBus, bufferSize: UInt32((inputFormat.sampleRate * frameLength) / sampleRate), format: inputFormat) { [weak self] buffer, _ in
+            print("b", buffer)
+            guard let self else { return }
+            var newBufferAvailable = true
+            
+            let inputCallback: AVAudioConverterInputBlock = { inNumPackets, outStatus in
+                if newBufferAvailable {
+                    outStatus.pointee = .haveData
+                    newBufferAvailable = false
+                    
+                    return buffer
+                } else {
+                    outStatus.pointee = .noDataNow
+                    return nil
+                }
+            }
+            
+            let capacity = AVAudioFrameCount(outputFormat.sampleRate) * buffer.frameLength / AVAudioFrameCount(buffer.format.sampleRate)
+            
+            let convertedBuffer = AVAudioPCMBuffer(pcmFormat: outputFormat, frameCapacity: capacity)!
+            
+            var error: NSError?
+            let _ = converter.convert(to: convertedBuffer, error: &error, withInputFrom: inputCallback)
+            
+            let intData = convertedBuffer.floatChannelData!
+            
+            var newFrames: [Double] = []
+            for channelIdx in 0..<1 {
+                newFrames += Array(UnsafeBufferPointer(start: intData[channelIdx], count: Int(convertedBuffer.frameLength))).map{ Double($0)}
+            }
+            
+            if  newFrames.count != Int(frameLength) {
+                print("unexpected buffer length", newFrames.count)
+                return
+            }
+            print("newFrames", newFrames)
+            self.onBuffer?(newFrames)
+        }
+        requestMicrophonePermissions()
+    }
+
+    public func start() throws {
+
+        try AVAudioSession.sharedInstance().setCategory(.playAndRecord, mode: .default, options: [.defaultToSpeaker])
+        try AVAudioSession.sharedInstance().setActive(true)
+        engine.prepare()
+        try engine.start()
+    }
+
+    public func stop() {
+        engine.inputNode.removeTap(onBus: inputBus)
+        engine.stop()
+    }
+    
+    private func requestMicrophonePermissions(
+    ) {
+        switch AVAudioSession.sharedInstance().recordPermission {
+        case .undetermined:
+            AVAudioSession.sharedInstance().requestRecordPermission { isAllowed in
+                
+            }
+        @unknown default: break
+            
+        }
+    }
+}

Example/KWSExample/KWSExample/Assets.xcassets/AppIcon.appiconset/Contents.json

@@ -0,0 +1,89 @@
+//
+//  ContentView.swift
+//  KWSExample
+//
+//  Created by Marat Zainullin on 12/06/2025.
+//
+
+import SwiftUI
+import OtosakuKWS
+
+struct ContentView: View {
+    @ObservedObject private var observer: Observer = Observer()
+
+    var body: some View {
+        VStack(spacing: 24) {
+            Text("🎙️ Otosaku KWS Demo")
+                .font(.largeTitle.bold())
+
+            if let keyword = observer.detectedKeyword, let score = observer.confidence {
+                Text("✅ Detected: **\(keyword)**")
+                    .font(.title2)
+                    .foregroundColor(.green)
+
+                Text("Confidence: \(String(format: "%.2f", score))")
+                    .font(.subheadline)
+                    .foregroundColor(.secondary)
+            } else {
+                Text("Listening...")
+                    .font(.title2)
+                    .foregroundColor(.gray)
+            }
+
+            if observer.recordWasStarted {
+                ProgressView()
+                    .progressViewStyle(CircularProgressViewStyle(tint: .blue))
+                    .scaleEffect(1.5)
+            }
+
+            Spacer()
+        }
+        .padding()
+        .onAppear {
+            observer.startRecording()
+//            setupKWS()
+        }
+        .onDisappear {
+            observer.stop()
+        }
+    }
+
+//    private func setupKWS() {
+//        Task {
+//            do {
+//                let modelRoot = Bundle.main.resourceURL!
+//                let featurizerRoot = Bundle.main.resourceURL!
+//
+//                let kws = try OtosakuKWS(
+//                    modelRootURL: modelRoot,
+//                    featureExtractorRootURL: featurizerRoot,
+//                    configuration: .init()
+//                )
+//
+//                kws.setProbabilityThreshold(0.9)
+//
+//                kws.onKeywordDetected = { keyword, score in
+//                    detectedKeyword = keyword
+//                    confidence = score
+//
+//                    DispatchQueue.main.asyncAfter(deadline: .now() + 2.0) {
+//                        detectedKeyword = nil
+//                        confidence = nil
+//                    }
+//                }
+//
+//                let audioInput = AudioStreamer()
+//
+//                audioInput.onBuffer = { buffer in
+//                    Task {
+//                        await kws.handleAudioBuffer(buffer)
+//                    }
+//                }
+//
+//                try audioInput.start()
+//            } catch {
+//                print("🚨 Error setting up KWS: \(error)")
+//            }
+//        }
+//    }
+}