Skip to content

Continous Stroker Mode #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Nexxom wants to merge 2 commits into
base: krelbel_dev
Choose a base branch
from
Open

Continous Stroker Mode #2

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3b07d4d
Update BPIOClient.py
Nexxom Jun 5, 2023
592b028
Update BPIOClient.py
Nexxom Jun 5, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
71 changes: 58 additions & 13 deletions BPIOClient.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,19 +48,29 @@ async def buzz(ctx: BPIOContext, duration: float = 0.5, singlebuzz: bool = True)
if ctx.bpenable:
for dev in ctx.client.devices.values():
for linear_actuator in dev.linear_actuators:

#Flip Duration
if duration <= 0:
logger.error("Error: Duration can't be equal or less than 0")
duration = 3 / duration
#if at bottom or going down send to top
if ctx.bplinpos == 0:
ctx.bplinpos = 1
await linear_actuator.command(int(duration * 1000), 1)
#otherwise send to bottom
else:
ctx.bplinpos = 0
await linear_actuator.command(int(duration * 1000), 0)
if not ctx.bplinstart:
#Flip Duration
if duration <= 0:
logger.error("Error: Duration can't be equal or less than 0")
duration = 3 / duration
#if at bottom or going down send to top
if ctx.bplinpos == 0:
ctx.bplinpos = 1
await linear_actuator.command(int(duration * 1000), 1)
#otherwise send to bottom
else:
ctx.bplinpos = 0
await linear_actuator.command(int(duration * 1000), 0)
elif ctx.bplinstart:
newSpeed = ctx.bplinspeed - int((duration/2)*1000)
if newSpeed < 200:
while newSpeed < 200:
ctx.bplinmaxsstrokes += 1
newSpeed += 200
ctx.bplinspeed = 200
else:
ctx.bplinspeed = newSpeed


for dev in ctx.client.devices.values():
for actuator in dev.actuators:
Expand All @@ -73,11 +83,31 @@ async def buzz(ctx: BPIOContext, duration: float = 0.5, singlebuzz: bool = True)
# Only turn vibrations off if we know this isn't part of a sequence of
# different intensity vibrations, to avoid stuttering
if not singlebuzz:

return

await haltbuzz(ctx)
ctx.bplock.release()

async def bpstroke(ctx: BPIOContext):
if ctx.bpenable:
while ctx.bplinstart:
for dev in ctx.client.devices.values():
for linear_actuator in dev.linear_actuators:
if ctx.bplinpos == 0:
ctx.bplinpos = 1
else:
ctx.bplinpos = 0
await linear_actuator.command(ctx.bplinspeed, ctx.bplinpos)
await asyncio.sleep(float(ctx.bplinspeed)/1000)
if ctx.bplinmaxsstrokes > 0:
ctx.bplinmaxsstrokes -= 1
else:
ctx.bplinspeed += 50
if ctx.bplinspeed > 2000:
ctx.bplinspeed = 2000


async def bpconnect(ctx: BPIOContext, ccp: BPIOClientCommandProcessor):
try:
await ctx.client.connect(ctx.connector)
Expand Down Expand Up @@ -166,6 +196,18 @@ def _cmd_bpenable(self):
self.output(f"Reenabling BP queue")
self.ctx.bpenable = True

def _cmd_bpsstart(self):
"""Start linear toy"""
self.output(f"Motion Ready!")
self.ctx.bplinstart = True
asyncio.create_task(bpstroke(self.ctx))

def _cmd_bpsstop(self):
"""Stop linear toy"""
self.output(f"Motion Stopped!")
self.ctx.bplinstart = False


if __name__ == '__main__':

class BPIOContext(CommonContext):
Expand All @@ -180,6 +222,9 @@ class BPIOContext(CommonContext):
strength = 0.5
bpenable = False
bplinpos = 1 #saved linear position 0-bottom 1-top
bplinstart = False
bplinspeed = 2000
bplinmaxsstrokes = 0

async def server_auth(self, password_requested: bool = False):
if password_requested and not self.password:
Expand Down