ショップアイテムのローテーション入門

Last updated on July 14, 2026

注釈：本資料はAI技術を用いて翻訳されています。

Overview

この記事では、ショップアイテムのローテーションおよびショップセクションアイテムのバックフィルのために Extend Override アプリで使用される API コントラクト (Protobuf) について説明します。

service SectionService {
  /**
    GetRotationItems: get current rotation items, this method will be called by rotation type is CUSTOM
   */
  rpc GetRotationItems(GetRotationItemsRequest) returns (GetRotationItemsResponse);

  /**
   Backfill method trigger condition:
   1. Rotation type is FIXED_PERIOD
   2. Bulkfill type is CUSTOM
   3. User already owned any one of current rotation items.
   */
  rpc Backfill(BackfillRequest) returns (BackfillResponse);
}

API Contract

GetRotationItems

このメソッドは、ローテーションタイプが CUSTOM のストア表示セクションに対して、AGS プラットフォームの Commerce サービスによって呼び出されます。この関数は、ユーザーがアクティブな表示セクションを取得しようとしたときに呼び出されます。開発者は、特定のユーザーのリクエストに対して、指定されたゲーム内ストアセクションに何を表示するかを決定するロジックを実装できます。

この例では、GetRotationItems のロジックを実装して、1 時間ごとにローテーションされる異なるアイテムを返すようにします。

C#

アプリでは、次の関数が src/AccelByte.PluginArch.ItemRotation.Demo.Server/Services/SectionFunctionService.cs にあります。

public override Task<GetRotationItemsResponse> GetRotationItems(GetRotationItemsRequest request, ServerCallContext context)
{
    List<SectionItemObject> items = new List<SectionItemObject>(request.SectionObject.Items);
    float inputCount = items.Count;

    
    float currentPoint = DateTime.Now.Hour;
    int selectedIndex = (int)Math.Floor((inputCount / _UpperLimit) * currentPoint);

    SectionItemObject selectedItem = items[selectedIndex];

    GetRotationItemsResponse response = new GetRotationItemsResponse();
    response.ExpiredAt = 0;
    response.Items.Add(selectedItem);

    return Task.FromResult(response);
}

Go

アプリでは、次の関数が pkg/service/section_service.go にあります。

func (s SectionServiceServer) GetRotationItems(ctx context.Context, request *pb.GetRotationItemsRequest) (*pb.GetRotationItemsResponse, error) {
	inputCount := len(request.GetSectionObject().GetItems())
	currentPoint := time.Now().Hour()
	selectedIndex := int(math.Floor((float64(inputCount) / float64(upperLimit)) * float64(currentPoint)))
	selectedItem := request.GetSectionObject().GetItems()[selectedIndex]

	responseItems := []*pb.SectionItemObject{
		{
			ItemId:  selectedItem.ItemId,
			ItemSku: selectedItem.ItemSku,
		},
	}

	resp := pb.GetRotationItemsResponse{
		Items:     responseItems,
		ExpiredAt: 0,
	}

	return &resp, nil
}

Java

アプリでは、次の関数が src/main/java/net/accelbyte/service/SectionServiceImplementation.java にあります。

@Override
public void getRotationItems(GetRotationItemsRequest request, StreamObserver<GetRotationItemsResponse> responseObserver) {
    
    List<SectionItemObject> items = request.getSectionObject().getItemsList();
    final int inputCount = items.size();

    final float currentPoint = (float) LocalDateTime.now().getHour();
    final int selectedIndex = (int)Math.floor((inputCount/upperLimit)*currentPoint);

    SectionItemObject selectedItem = items.get(selectedIndex);
    List<SectionItemObject> responseItems = new ArrayList<>();
    responseItems.add(selectedItem);

    GetRotationItemsResponse response = GetRotationItemsResponse
            .newBuilder()
            .setExpiredAt(0)
            .addAllItems(responseItems)
            .build();

    responseObserver.onNext(response);
    responseObserver.onCompleted();
}

Python

アプリでは、次の関数が src/app/services/section_service.py にあります。

async def GetRotationItems(self, request : GetRotationItemsRequest, context):
    """*
    GetRotationItems: get current rotation items, this method will be called by rotation type is CUSTOM
    """
    self.log_payload(f'{self.GetRotationItems.__name__} request: %s', request)
    items : List[SectionItemObject] = request.sectionObject.items
    input_count : int = len(items)
    current_point : float = float(datetime.now().hour)
    selected_index : int = int(math.floor((input_count/self.upper_limit)*current_point))
    selected_item : SectionItemObject = items[selected_index]
    response_items : List[SectionItemObject] = [selected_item]
    response : GetRotationItemsResponse = GetRotationItemsResponse(expiredAt=0, items=response_items)
    self.log_payload(f'{self.GetRotationItems.__name__} response: %s', response)
    return response

Backfill

Backfill は、セクションのローテーションタイプが FIXED_PERIOD、バックフィルタイプが CUSTOM で、現在のアイテムローテーションに既に所有済みのアイテムが含まれている場合に呼び出されます。このユースケースの一例として、所有済みアイテムを置き換えるロジックを実装できます。

この例では、既に所有しているアイテムを、その現在のインデックスで新しいランダムなアイテム ID に置き換えます。

C#

アプリでは、次の関数が src/AccelByte.PluginArch.ItemRotation.Demo.Server/Services/SectionFunctionService.cs にあります。

public override Task<BackfillResponse> Backfill(BackfillRequest request, ServerCallContext context)
{
    BackfillResponse response = new BackfillResponse();

    foreach (var item in request.Items)
    {
        if (item.Owned)
        {
            BackfilledItemObject newItem = new BackfilledItemObject()
            {
                ItemId = Guid.NewGuid().ToString().Replace("-", ""),
                Index = item.Index
            };
            response.BackfilledItems.Add(newItem);
        }
    }

    return Task.FromResult(response);
}

Go

アプリでは、次の関数が pkg/service/section_service.go にあります。

func (s SectionServiceServer) Backfill(ctx context.Context, request *pb.BackfillRequest) (*pb.BackfillResponse, error) {
	var newItems []*pb.BackfilledItemObject
	for _, item := range request.GetItems() {
		if item.Owned {
			// if an item is owned by user, then replace it with new item id.
			// item id will be generated randomly for example purpose.
			newItem := &pb.BackfilledItemObject{
				ItemId: strings.ReplaceAll(uuid.NewString(), "-", ""),
				Index:  item.Index,
			}

			newItems = append(newItems, newItem)
		}
	}

	resp := &pb.BackfillResponse{BackfilledItems: newItems}

	return resp, nil
}

Java

アプリでは、次の関数が src/main/java/net/accelbyte/service/SectionServiceImplementation.java にあります。

@Override
public void backfill(BackfillRequest request, StreamObserver<BackfillResponse> responseObserver) {
    
    List<BackfilledItemObject> newItems = new ArrayList<>();
    for(RotationItemObject item : request.getItemsList()) {
        if (item.getOwned()) {
            BackfilledItemObject newItem = BackfilledItemObject
                    .newBuilder()
                    .setItemId(UUID.randomUUID().toString().replace("-",""))
                    .setIndex(item.getIndex())
                    .build();
            newItems.add(newItem);
        }
    }

    BackfillResponse response = BackfillResponse
            .newBuilder()
            .addAllBackfilledItems(newItems)
            .build();

    responseObserver.onNext(response);
    responseObserver.onCompleted();
}

Python

アプリでは、次の関数が src/app/services/section_service.py にあります。

async def Backfill(self, request : BackfillRequest, context):
    """*
    Backfill method trigger condition:
    1. Rotation type is FIXED_PERIOD
    2. Backfill type is CUSTOM
    3. User already owned any one of current rotation items.
    """
    self.log_payload(f'{self.Backfill.__name__} request: %s', request)
    new_items : List[BackfilledItemObject] = []
    item : RotationItemObject
    for item in request.items:
            if item.owned:
                new_item : BackfilledItemObject = BackfilledItemObject(itemId=str(uuid.uuid4()).replace("-",""), index=item.index)
                new_items.append(new_item)
    response : BackfillResponse = BackfillResponse(backfilledItems=new_items)
    self.log_payload(f'{self.Backfill.__name__} response: %s', response)
    return response

備考

gRPC リクエストの処理に関する詳細はこちらを参照してください。